From 1a3d118090e9b607ccc06ab1acad223678137e8e Mon Sep 17 00:00:00 2001 From: Jeff Widman Date: Wed, 19 Jun 2019 13:36:57 -0700 Subject: Combine two `poll_ms` defs into one --- kafka/consumer/group.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) (limited to 'kafka/consumer/group.py') diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index 823ec41..6df2b0f 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -1069,8 +1069,7 @@ class KafkaConsumer(six.Iterator): partitions = self._subscription.missing_fetch_positions() self._update_fetch_positions(partitions) - poll_ms = 1000 * (self._consumer_timeout - time.time()) - poll_ms = min(poll_ms, self.config['retry_backoff_ms']) + poll_ms = min((1000 * (self._consumer_timeout - time.time())), 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