Revert "bugfix: raise error in check_version if broker is unavailable"

Author: keejon

kafka/client_async.py

@@ -911,8 +911,7 @@ def check_version(self, node_id=None, timeout=2, strict=False):
             if try_node is None:
                 self._lock.release()
                 raise Errors.NoBrokersAvailable()
-            if not self._maybe_connect(try_node):
-                raise Errors.BrokerNotAvailableError()
+            self._maybe_connect(try_node)
             conn = self._conns[try_node]
 
             # We will intentionally cause socket failures