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'])