better logging for consumer

tkaemming · Dec 9, 2015 · 7f967ac · 7f967ac
1 parent f0fcdce
commit 7f967ac
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafkaesque.py b/kafkaesque.py
@@ -84,7 +84,7 @@ def consume(topic, consumer_id, follow):
 
     while True:
         cursor, batch = topic.consume(cursor)
-        logger.debug('Retrieved %s items.', len(batch))
+        logger.debug('Retrieved %s items from %s to %s.', len(batch), cursor, cursor + len(batch))
         if not batch:
             if not follow:
                 logger.debug('Retrieved empty batch (end of stream.)')