diff --git a/kafka/client_async.py b/kafka/client_async.py
index 2e3a680ff..a9dfd166b 100644
--- a/kafka/client_async.py
+++ b/kafka/client_async.py
@@ -911,7 +911,8 @@ def check_version(self, node_id=None, timeout=2, strict=False):
             if try_node is None:
                 self._lock.release()
                 raise Errors.NoBrokersAvailable()
-            self._maybe_connect(try_node)
+            if not self._maybe_connect(try_node):
+                raise Errors.BrokerNotAvailableError()
             conn = self._conns[try_node]
 
             # We will intentionally cause socket failures