From 7907c9beeca0143de32a5b575fa30c4afe582fc3 Mon Sep 17 00:00:00 2001 From: Jonas Keeling Date: Mon, 26 Feb 2024 10:29:17 +0100 Subject: [PATCH] Revert "bugfix: raise error in check_version if broker is unavailable" --- kafka/client_async.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/kafka/client_async.py b/kafka/client_async.py index a9dfd166b..2e3a680ff 100644 --- a/kafka/client_async.py +++ b/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