def create_message(payload, key=None):
return Message(<NUM_LIT:0>, <NUM_LIT:0>, key, payload)<EOL>
Construct a Message

Arguments:
    payload: bytes, the payload to send to Kafka
    key: bytes, a key used for partition routing (optional)