From dc7a21151be7c10d446edbfeb80a80fca12a2994 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Mon, 14 Mar 2016 10:52:04 -0700
Subject: KafkaConsumer.poll should sleep to prevent tight-loops

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

diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py
index a4381a9..32a4a49 100644
--- a/kafka/consumer/group.py
+++ b/kafka/consumer/group.py
@@ -465,7 +465,7 @@ class KafkaConsumer(six.Iterator):
             return records
 
         self._fetcher.init_fetches()
-        self._client.poll(timeout_ms)
+        self._client.poll(timeout_ms=timeout_ms, sleep=True)
         return self._fetcher.fetched_records()
 
     def position(self, partition):
-- 
cgit v1.2.1