diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-05-22 10:28:56 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-05-22 10:28:56 -0700 |
| commit | 7941a2ac7ec6663f08c6291d92746eae9f792916 (patch) | |
| tree | f3b75dcea569e28f1685500af53bff34514374b9 /kafka/protocol/legacy.py | |
| parent | 92f859d8da5c3f35ab3738ef2725fff05b6cf57f (diff) | |
| parent | aa5bde6ac382966395f8f1466c46d55cf28c2cce (diff) | |
| download | kafka-python-7941a2ac7ec6663f08c6291d92746eae9f792916.tar.gz | |
Merge pull request #693 from dpkp/message_format_v1
Message format v1 (KIP-31 / KIP-32)
Diffstat (limited to 'kafka/protocol/legacy.py')
| -rw-r--r-- | kafka/protocol/legacy.py | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/kafka/protocol/legacy.py b/kafka/protocol/legacy.py index cd100d6..6ab2511 100644 --- a/kafka/protocol/legacy.py +++ b/kafka/protocol/legacy.py @@ -143,9 +143,11 @@ class KafkaProtocol(object): topic, [( partition, - [(0, 0, kafka.protocol.message.Message(msg.value, key=msg.key, - magic=msg.magic, - attributes=msg.attributes)) + [(0, + kafka.protocol.message.Message( + msg.value, key=msg.key, + magic=msg.magic, attributes=msg.attributes + ).encode()) for msg in payload.messages]) for partition, payload in topic_payloads.items()]) for topic, topic_payloads in group_by_topic_and_partition(payloads).items()]) |