We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6c2c25d commit 9dd1714Copy full SHA for 9dd1714
kafka/client_async.py
@@ -276,6 +276,7 @@ def __init__(self, **configs):
276
if compatible_version:
277
log.warning('Configured api_version %s not supported; using %s',
278
self.config['api_version'], compatible_version)
279
+ self.config['api_version'] = compatible_version
280
self._api_versions = BROKER_API_VERSIONS[compatible_version]
281
else:
282
raise Errors.UnrecognizedBrokerVersion(self.config['api_version'])
0 commit comments