diff options
Diffstat (limited to 'kafka/protocol/message.py')
| -rw-r--r-- | kafka/protocol/message.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/kafka/protocol/message.py b/kafka/protocol/message.py index f5a51a9..a330ed8 100644 --- a/kafka/protocol/message.py +++ b/kafka/protocol/message.py @@ -161,7 +161,8 @@ class MessageSet(AbstractType): if prepend_size: # rewind and return all the bytes items.seek(items.tell() - 4) - return items.read(size + 4) + size += 4 + return items.read(size) encoded_values = [] for (offset, message) in items: |