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 10aa4ba commit 6a361a8Copy full SHA for 6a361a8
kafka/coordinator/base.py
@@ -453,9 +453,7 @@ def _send_join_group_request(self):
453
for protocol, metadata in self.group_protocols()
454
]
455
version = self._client.api_version(JoinGroupRequest, max_version=2)
456
- if not version:
457
- raise Errors.KafkaError('JoinGroupRequest api requires 0.9+ brokers')
458
- elif version == 0:
+ if version == 0:
459
request = JoinGroupRequest[version](
460
self.group_id,
461
self.config['session_timeout_ms'],
0 commit comments