From 37ed766c92e81b8c2330559688768babaf80c6ae Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Tue, 28 May 2019 23:58:43 -0700 Subject: Reduce internal client poll timeout for consumer interator interface --- kafka/consumer/group.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index b3e182c..823ec41 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -1070,8 +1070,7 @@ class KafkaConsumer(six.Iterator): self._update_fetch_positions(partitions) poll_ms = 1000 * (self._consumer_timeout - time.time()) - if not self._fetcher.in_flight_fetches(): - poll_ms = min(poll_ms, self.config['reconnect_backoff_ms']) + poll_ms = min(poll_ms, self.config['retry_backoff_ms']) self._client.poll(timeout_ms=poll_ms) # after the long poll, we should check whether the group needs to rebalance -- cgit v1.2.1