Skip to content

Commit 990e928

Browse files
ckyoogdpkp
authored andcommitted
Fix consumer poll stuck error when no available partition (#1375)
1 parent 8655c75 commit 990e928

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka/coordinator/consumer.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -462,7 +462,7 @@ def commit_offsets_async(self, offsets, callback=None):
462462
# its completion). Note that commits are treated as heartbeats by the
463463
# coordinator, so there is no need to explicitly allow heartbeats
464464
# through delayed task execution.
465-
self._client.poll() # no wakeup if we add that feature
465+
self._client.poll(timeout_ms=0) # no wakeup if we add that feature
466466

467467
def _do_commit_offsets_async(self, offsets, callback=None):
468468
assert self.config['api_version'] >= (0, 8, 1), 'Unsupported Broker API'

0 commit comments

Comments
 (0)