From 254c17e39fb8790957da792acdd7e435551a9ac6 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@rd.io>
Date: Tue, 1 Dec 2015 16:20:33 -0800
Subject: Add comment re bytes offset tracking in MessageSet decode()

---
 kafka/protocol/message.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'kafka/protocol')

diff --git a/kafka/protocol/message.py b/kafka/protocol/message.py
index 4f84c43..c3265f9 100644
--- a/kafka/protocol/message.py
+++ b/kafka/protocol/message.py
@@ -65,7 +65,7 @@ class MessageSet(AbstractType):
         while bytes_read < size:
             items.append(cls.ITEM.decode(data))
             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
 
     @classmethod
-- 
cgit v1.2.1