openstack/deb-python-kafka
Code Issues Proposed changes

Minor additional logging for consumer coordinator

Browse Source
This commit is contained in:
Dana Powers
2017-03-06 11:03:17 -08:00
parent 8ebb646be9
commit ff6f7bf085
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/coordinator/base.py
View File

@@ -215,6 +215,7 @@ class BaseCoordinator(object):
if future.failed():
if future.retriable():
if getattr(future.exception, 'invalid_metadata', False):
log.debug('Requesting metadata for group coordinator request: %s', future.exception)
metadata_update = self._client.cluster.request_update()
self._client.poll(future=metadata_update)
else:
@@ -532,6 +533,7 @@ class BaseCoordinator(object):
if not self.coordinator_unknown() and self.generation > 0:
# this is a minimal effort attempt to leave the group. we do not
# attempt any resending if the request fails or times out.
log.info('Leaving consumer group (%s).', self.group_id)
request = LeaveGroupRequest[0](self.group_id, self.member_id)
future = self._client.send(self.coordinator_id, request)
future.add_callback(self._handle_leave_group_response)