From 09ac0598f75532981a37b9256f90054a90df367f Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Tue, 25 Mar 2025 08:38:26 -0700 Subject: [PATCH] Also update config api_version to closest compatible --- kafka/client_async.py | 1 + 1 file changed, 1 insertion(+) diff --git a/kafka/client_async.py b/kafka/client_async.py index 4de05b33e..8df4566e6 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -276,6 +276,7 @@ def __init__(self, **configs): if compatible_version: log.warning('Configured api_version %s not supported; using %s', self.config['api_version'], compatible_version) + self.config['api_version'] = compatible_version self._api_versions = BROKER_API_VERSIONS[compatible_version] else: raise Errors.UnrecognizedBrokerVersion(self.config['api_version'])