openstack/deb-python-kafka
Code Issues Proposed changes

_handle_group_coordinator_response should resolve future with the coordinator id

Browse Source
This commit is contained in:
Dana Powers
2015-12-29 17:21:25 -08:00
parent f82eb8cdf6
commit 8811326443
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/coordinator/abstract.py
View File

@@ -440,7 +440,7 @@ class AbstractCoordinator(object):
# start sending heartbeats only if we have a valid generation # start sending heartbeats only if we have a valid generation
if self.generation > 0: if self.generation > 0:
self.heartbeat_task.reset() self.heartbeat_task.reset()
future.success(None) future.success(self.coordinator_id)
elif error_type is Errors.GroupAuthorizationFailedError: elif error_type is Errors.GroupAuthorizationFailedError:
error = error_type(self.group_id) error = error_type(self.group_id)
log.error("Group Coordinator Request failed: %s", error) log.error("Group Coordinator Request failed: %s", error)