From 298369afb1c2f30ea10adce1c171bf1e2202391a Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@rd.io>
Date: Wed, 7 Mar 2018 11:38:04 -0800
Subject: Avoid tight poll loop in consumer when brokers are down

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

(limited to 'kafka/consumer/group.py')

diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py
index 110df55..f6f1a67 100644
--- a/kafka/consumer/group.py
+++ b/kafka/consumer/group.py
@@ -1059,7 +1059,7 @@ class KafkaConsumer(six.Iterator):
 
             poll_ms = 1000 * (self._consumer_timeout - time.time())
             if not self._fetcher.in_flight_fetches():
-                poll_ms = 0
+                poll_ms = min(poll_ms, self.config['reconnect_backoff_ms'])
             self._client.poll(timeout_ms=poll_ms)
 
             # after the long poll, we should check whether the group needs to rebalance
-- 
cgit v1.2.1