openstack/deb-python-kafka
Code Issues Proposed changes

Catch GroupCoordinatorNotAvailableError in GroupCoordinatorResponse handler

Browse Source
This commit is contained in:
Dana Powers
2015-12-30 13:17:16 -08:00
parent 61c6e18408
commit 59c0513148
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
kafka/coordinator/abstract.py
View File

@@ -470,6 +470,9 @@ class AbstractCoordinator(object):
if self.generation > 0:
self.heartbeat_task.reset()
future.success(self.coordinator_id)
elif error_type is Errors.GroupCoordinatorNotAvailableError:
log.debug("Group Coordinator Not Available; retry")
future.failure(error_type())
elif error_type is Errors.GroupAuthorizationFailedError:
error = error_type(self.group_id)
log.error("Group Coordinator Request failed: %s", error)