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 a5d4611 commit 747a1c1Copy full SHA for 747a1c1
kafka/conn.py
@@ -521,6 +521,7 @@ def _try_api_versions_check(self):
521
if self.config['api_version'] is not None:
522
self._api_version = self.config['api_version']
523
self._api_versions = BROKER_API_VERSIONS[self._api_version]
524
+ log.debug('%s: Using pre-configured api_version %s for ApiVersions', self, self._api_version)
525
return True
526
elif self._check_version_idx is None:
527
request = ApiVersionsRequest[self._api_versions_idx]()
0 commit comments