openstack/deb-python-kafka
Code Issues Proposed changes

Ok to sleep in blocking poll for metadata update

Browse Source
This commit is contained in:
Dana Powers
2016-01-25 16:01:53 -08:00
parent a667a4b3be
commit a154d0471c
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/consumer/fetcher.py
View File

@@ -217,7 +217,7 @@ class Fetcher(six.Iterator):
if future.exception.invalid_metadata: if future.exception.invalid_metadata:
refresh_future = self._client.cluster.request_update() refresh_future = self._client.cluster.request_update()
self._client.poll(future=refresh_future) self._client.poll(future=refresh_future, sleep=True)
def _raise_if_offset_out_of_range(self): def _raise_if_offset_out_of_range(self):
"""Check FetchResponses for offset out of range. """Check FetchResponses for offset out of range.

2
kafka/coordinator/base.py
View File

@@ -205,7 +205,7 @@ class BaseCoordinator(object):
continue continue
elif future.retriable(): elif future.retriable():
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, sleep=True)
else: else:
raise future.exception # pylint: disable-msg=raising-bad-type raise future.exception # pylint: disable-msg=raising-bad-type