From 77c1818a080b62704e8f406d5418345f73053409 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sun, 6 Aug 2017 17:49:38 -0700 Subject: Drop unused sleep kwarg to poll --- kafka/consumer/fetcher.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) (limited to 'kafka/consumer/fetcher.py') diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index c0d6075..10ed187 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -275,8 +275,7 @@ class Fetcher(six.Iterator): if future.exception.invalid_metadata: refresh_future = self._client.cluster.request_update() - self._client.poll( - future=refresh_future, sleep=True, timeout_ms=remaining_ms) + self._client.poll(future=refresh_future, timeout_ms=remaining_ms) else: time.sleep(self.config['retry_backoff_ms'] / 1000.0) -- cgit v1.2.1