diff options
| author | Mahendra M <mahendra.m@gmail.com> | 2013-06-27 17:51:12 +0530 |
|---|---|---|
| committer | Mahendra M <mahendra.m@gmail.com> | 2013-06-27 17:51:12 +0530 |
| commit | c2a49c1370536e7155c34bb93fa14a23f367d5f4 (patch) | |
| tree | e1e714d2587ee6e370c2bdb7a8b4e01c80eef798 | |
| parent | 36b5f8154304a7fef437795250885230dff835b1 (diff) | |
| download | kafka-python-c2a49c1370536e7155c34bb93fa14a23f367d5f4.tar.gz | |
Add TODO comments
| -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 |