diff options
| author | Taras <voyn1991@gmail.com> | 2017-10-12 11:07:14 +0300 |
|---|---|---|
| committer | Taras <voyn1991@gmail.com> | 2017-10-12 11:10:44 +0300 |
| commit | d10051bb09942bfd48c6f262a8cdbf5651963c2e (patch) | |
| tree | 1f6a262324e3ced9c8655d71fbed5e9ed8a0234d /kafka/protocol/message.py | |
| parent | e992fbfad926486766ff7b63a499f9cf29984fec (diff) | |
| download | kafka-python-d10051bb09942bfd48c6f262a8cdbf5651963c2e.tar.gz | |
Added minor fixes for PR review
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: |