diff options
| author | Omar Ghishan <omar.ghishan@rd.io> | 2013-12-19 11:36:15 -0800 |
|---|---|---|
| committer | Omar Ghishan <omar.ghishan@rd.io> | 2014-01-06 15:14:50 -0800 |
| commit | b68523fd28dec0741a15cbb3b5a78d954c559d2d (patch) | |
| tree | fa3cf753444acd7c64a84d48c72ef08382f44c4a /kafka | |
| parent | 0c7cf2569e384fcdde67b86689d64bafbaed953f (diff) | |
| download | kafka-python-b68523fd28dec0741a15cbb3b5a78d954c559d2d.tar.gz | |
Remove SimpleConsumer queue size limit since it can cause the iterator
to block forever if it's reached.
Diffstat (limited to 'kafka')
| -rw-r--r-- | kafka/consumer.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/consumer.py b/kafka/consumer.py index a5a3e26..b27b845 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -227,7 +227,7 @@ class SimpleConsumer(Consumer): self.fetch_max_wait_time = FETCH_MAX_WAIT_TIME self.fetch_min_bytes = fetch_size_bytes self.fetch_started = defaultdict(bool) # defaults to false - self.queue = Queue(buffer_size) + self.queue = Queue() super(SimpleConsumer, self).__init__( client, group, topic, |