From 6662d1e6247f809b04a8fc7cb539a5dd02ed9b65 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Thu, 7 Apr 2016 16:13:50 -0700
Subject: Default sleep=True in client.poll

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

(limited to 'kafka/consumer')

diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py
index 6c85c21..151e644 100644
--- a/kafka/consumer/group.py
+++ b/kafka/consumer/group.py
@@ -743,7 +743,7 @@ class KafkaConsumer(six.Iterator):
             poll_ms = 1000 * (self._consumer_timeout - time.time())
             if not self._fetcher.in_flight_fetches():
                 poll_ms = 0
-            self._client.poll(poll_ms)
+            self._client.poll(timeout_ms=poll_ms, sleep=True)
 
             # We need to make sure we at least keep up with scheduled tasks,
             # like heartbeats, auto-commits, and metadata refreshes
-- 
cgit v1.2.1