set _api_versions during bootstrap

Author: dpkp

kafka/client_async.py

@@ -338,6 +338,8 @@ def _conn_state_change(self, node_id, sock, conn):
 
                 if self.cluster.is_bootstrap(node_id):
                     self._bootstrap_fails = 0
+                    if self._api_versions is None:
+                        self._api_versions = conn._api_versions
 
                 else:
                     for node_id in list(self._conns.keys()):
@@ -939,7 +941,7 @@ def refresh_done(val_or_error):
     def get_api_versions(self):
         """Return the ApiVersions map, if available.
 
-        Note: Only available after first connection to any broker version 0.10.0 or later.
+        Note: Only available after bootstrap; requires broker version 0.10.0 or later.
 
         Returns: a map of dict mapping {api_key : (min_version, max_version)},
         or None if ApiVersion is not supported by the kafka cluster.
@@ -993,8 +995,6 @@ def check_version(self, node_id=None, timeout=None, **kwargs):
                     self.poll(timeout_ms=timeout_ms)
 
                 if conn._api_version is not None:
-                    if not self._api_versions:
-                        self._api_versions = conn._api_versions
                     return conn._api_version
 
             # Timeout