From b68523fd28dec0741a15cbb3b5a78d954c559d2d Mon Sep 17 00:00:00 2001
From: Omar Ghishan <omar.ghishan@rd.io>
Date: Thu, 19 Dec 2013 11:36:15 -0800
Subject: Remove SimpleConsumer queue size limit since it can cause the
 iterator to block forever if it's reached.

---
 kafka/consumer.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'kafka')

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,
-- 
cgit v1.2.1