From 1810816b00770c9aaf0e3175fe3d73d3ed19f81d Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Tue, 7 Mar 2017 11:32:36 -0800 Subject: For 0.8.2, only attempt connection to coordinator if least_loaded_node succeeds --- kafka/coordinator/base.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index 704fb85..e811e88 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -206,7 +206,8 @@ class BaseCoordinator(object): # it as the "coordinator" if self.config['api_version'] < (0, 8, 2): self.coordinator_id = self._client.least_loaded_node() - self._client.ready(self.coordinator_id) + if self.coordinator_id is not None: + self._client.ready(self.coordinator_id) continue future = self._send_group_coordinator_request() -- cgit v1.2.1