We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 36b5f81 commit c2a49c1Copy full SHA for c2a49c1
kafka/consumer.py
@@ -523,6 +523,8 @@ def __iter__(self):
523
try:
524
# We will block for a small while so that the consumers get
525
# 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
528
partition, message = self.queue.get(block=True, timeout=1)
529
except Empty:
530
break
0 commit comments