openstack
/
deb-python-kafka
Code Issues Proposed changes

For 0.8.2, only attempt connection to coordinator if least_loaded_node succeeds

This commit is contained in:
Dana Powers 2017-03-07 11:32:36 -08:00
parent 91cb3158e5
commit 1810816b00
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
kafka/coordinator/base.py
View File

@ -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()