From 2c02d65b7894443b55c86db9d32c99307e602b17 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Fri, 12 Jan 2018 14:57:57 -0800
Subject: revert poll timeout change

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

(limited to 'kafka/coordinator/base.py')

diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py
index 255efad..301c06d 100644
--- a/kafka/coordinator/base.py
+++ b/kafka/coordinator/base.py
@@ -936,7 +936,7 @@ class HeartbeatThread(threading.Thread):
             # TODO: When consumer.wakeup() is implemented, we need to
             # disable here to prevent propagating an exception to this
             # heartbeat thread
-            self.coordinator._client.poll(timeout_ms=self.coordinator.config['retry_backoff_ms'])
+            self.coordinator._client.poll(timeout_ms=0)
 
             if self.coordinator.coordinator_unknown():
                 if not self.coordinator.lookup_coordinator().is_done:
-- 
cgit v1.2.1