diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-07-17 14:16:27 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2016-07-17 14:16:27 -0700 |
| commit | deebefa6abb0c4e2bce47431b592a523fd49732e (patch) | |
| tree | b3530170dada8b1b0cccb3d217dee00da8cf519f /kafka/protocol/message.py | |
| parent | cd9aa73c8463fa0214d6ee6109c63396e623dbaa (diff) | |
| download | kafka-python-deebefa6abb0c4e2bce47431b592a523fd49732e.tar.gz | |
Always encode size with MessageSet (#771)
Diffstat (limited to 'kafka/protocol/message.py')
| -rw-r--r-- | kafka/protocol/message.py | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/kafka/protocol/message.py b/kafka/protocol/message.py index 656c131..795495d 100644 --- a/kafka/protocol/message.py +++ b/kafka/protocol/message.py @@ -143,7 +143,7 @@ class MessageSet(AbstractType): HEADER_SIZE = 12 # offset + message_size @classmethod - def encode(cls, items, size=True, recalc_message_size=True): + def encode(cls, items): # RecordAccumulator encodes messagesets internally if isinstance(items, io.BytesIO): size = Int32.decode(items) @@ -156,8 +156,6 @@ class MessageSet(AbstractType): encoded_values.append(Int64.encode(offset)) encoded_values.append(Bytes.encode(message)) encoded = b''.join(encoded_values) - if not size: - return encoded return Bytes.encode(encoded) @classmethod |