openstack/deb-python-kafka
Code Issues Proposed changes

Backoff on unavailable group coordinator retry

Browse Source
This commit is contained in:
Dana Powers
2017-06-18 23:55:39 -07:00
parent bbbac3dc36
commit 8a7d4cd66a
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

@@ -219,6 +219,8 @@ class BaseCoordinator(object):
log.debug('Requesting metadata for group coordinator request: %s', future.exception) log.debug('Requesting metadata for group coordinator request: %s', future.exception)
metadata_update = self._client.cluster.request_update() metadata_update = self._client.cluster.request_update()
self._client.poll(future=metadata_update) self._client.poll(future=metadata_update)
else:
time.sleep(self.config['retry_backoff_ms'] / 1000)
else: else:
raise future.exception # pylint: disable-msg=raising-bad-type raise future.exception # pylint: disable-msg=raising-bad-type