openstack/deb-python-kafka
Code Issues Proposed changes

Add comment re bytes offset tracking in MessageSet decode()

Browse Source
This commit is contained in:
Dana Powers
2015-12-01 16:20:33 -08:00
committed by Zack Dever
parent 235f7ac855
commit 254c17e39f
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/protocol/message.py
View File

@@ -65,7 +65,7 @@ class MessageSet(AbstractType):
while bytes_read < size: while bytes_read < size:
items.append(cls.ITEM.decode(data)) items.append(cls.ITEM.decode(data))
msg_size = items[-1][1] msg_size = items[-1][1]
bytes_read += (8 + 4 + msg_size) bytes_read += (8 + 4 + msg_size) # item size = 8 byte offset, 4 byte message_size, plus message bytes
return items return items
@classmethod @classmethod