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 d3a0479 commit 10022c4Copy full SHA for 10022c4
kafka/conn.py
@@ -536,7 +536,10 @@ def _try_handshake(self):
536
537
def _try_api_versions_check(self):
538
if self._api_versions_future is None:
539
- if self._check_version_idx is None:
+ if self.config['api_version'] is not None:
540
+ self._api_version = self.config['api_version']
541
+ return True
542
+ elif self._check_version_idx is None:
543
# TODO: Implement newer versions
544
# ((3, 9), ApiVersionsRequest[4]()),
545
# ((2, 4), ApiVersionsRequest[3]()),
0 commit comments