diff options
Diffstat (limited to 'kafka/consumer.py')
| -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, |