Skip to content

Commit 6c1dc22

Browse files
committed
fixup conn _api_versions when config set
1 parent dbc9a5b commit 6c1dc22

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

kafka/conn.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -543,6 +543,7 @@ def _try_api_versions_check(self):
543543
if self._api_versions_future is None:
544544
if self.config['api_version'] is not None:
545545
self._api_version = self.config['api_version']
546+
self._api_versions = BROKER_API_VERSIONS[self._api_version]
546547
return True
547548
elif self._check_version_idx is None:
548549
request = ApiVersionsRequest[self._api_versions_idx]()

0 commit comments

Comments
 (0)