Skip to content

Commit c2a49c1

Browse files
committed
Add TODO comments
1 parent 36b5f81 commit c2a49c1

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

kafka/consumer.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -523,6 +523,8 @@ def __iter__(self):
523523
try:
524524
# We will block for a small while so that the consumers get
525525
# a chance to run and put some messages in the queue
526+
# TODO: This is a hack and will make the consumer block for
527+
# at least one second. Need to find a better way of doing this
526528
partition, message = self.queue.get(block=True, timeout=1)
527529
except Empty:
528530
break

0 commit comments

Comments
 (0)