diff options
Diffstat (limited to 'kafka/coordinator/base.py')
| -rw-r--r-- | kafka/coordinator/base.py | 13 |
1 files 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) |