From a970870a744a913a90a274436f04d46aead6dd36 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Mon, 6 Mar 2017 10:33:12 -0800 Subject: Avoid unknown coordinator after client poll --- kafka/coordinator/base.py | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index e811e88..68b1bda 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -245,13 +245,12 @@ class BaseCoordinator(object): # ensure that there are no pending requests to the coordinator. # This is important in particular to avoid resending a pending # JoinGroup request. - if self._client.in_flight_request_count(self.coordinator_id): - while not self.coordinator_unknown(): - self._client.poll(delayed_tasks=False) - if not self._client.in_flight_request_count(self.coordinator_id): - break - else: - continue + while not self.coordinator_unknown(): + if not self._client.in_flight_request_count(self.coordinator_id): + break + self._client.poll(delayed_tasks=False) + else: + continue future = self._send_join_group_request() self._client.poll(future=future) -- cgit v1.2.1