We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
poll_ms
1 parent 37ed766 commit 1a3d118Copy full SHA for 1a3d118
kafka/consumer/group.py
@@ -1069,8 +1069,7 @@ def _message_generator(self):
1069
partitions = self._subscription.missing_fetch_positions()
1070
self._update_fetch_positions(partitions)
1071
1072
- poll_ms = 1000 * (self._consumer_timeout - time.time())
1073
- poll_ms = min(poll_ms, self.config['retry_backoff_ms'])
+ poll_ms = min((1000 * (self._consumer_timeout - time.time())), self.config['retry_backoff_ms'])
1074
self._client.poll(timeout_ms=poll_ms)
1075
1076
# after the long poll, we should check whether the group needs to rebalance
0 commit comments