Can no longer have coordinator_id if coordinator_unknown()

dpkp · dpkp · commit 88105af1f678 · 2016-04-07T17:07:33.000-07:00
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py
@@ -193,12 +193,6 @@ def ensure_coordinator_known(self):
         """
         while self.coordinator_unknown():
 
-            # Dont look for a new coordinator node if we are just waiting
-            # for connection to finish
-            if self.coordinator_id is not None:
-                self._client.poll()
-                continue
-
             future = self._send_group_coordinator_request()
             self._client.poll(future=future)
 
