Set the ASYNC_QUEUE_MAXSIZE to 65536

rogaha · rogaha · commit 1cad32a55432 · 2015-05-12T16:52:25.000-07:00
diff --git a/kafka/producer/base.py b/kafka/producer/base.py
@@ -27,8 +27,7 @@
 
 STOP_ASYNC_PRODUCER = -1
 
-# unlimited
-ASYNC_QUEUE_MAXSIZE = 0
+ASYNC_QUEUE_MAXSIZE = 65536
 
 
 def _send_upstream(queue, client, codec, batch_time, batch_size,
