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.
1 parent 79dd508 commit b469070Copy full SHA for b469070
kafka/coordinator/consumer.py
@@ -256,7 +256,7 @@ def poll(self):
256
ensures that the consumer has joined the group. This also handles
257
periodic offset commits if they are enabled.
258
"""
259
- if self.group_id is None or self.config['api_version'] < (0, 8, 2):
+ if self.group_id is None:
260
return
261
262
self._invoke_completed_offset_commit_callbacks()
0 commit comments