diff options
| -rw-r--r-- | kafka/consumer.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/kafka/consumer.py b/kafka/consumer.py index 5ca90de..9e6a0eb 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -523,6 +523,8 @@ class MultiProcessConsumer(Consumer): try: # We will block for a small while so that the consumers get # a chance to run and put some messages in the queue + # TODO: This is a hack and will make the consumer block for + # at least one second. Need to find a better way of doing this partition, message = self.queue.get(block=True, timeout=1) except Empty: break |