From 33a0a1b33d9ace831e7a6d78a7a49debeb5f56b5 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Tue, 12 May 2026 07:38:22 -0700 Subject: [PATCH] Coordinator: Drop ready check before FindCoordinatorRequest --- kafka/coordinator/base.py | 4 ---- 1 file changed, 4 deletions(-) diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index 28a33e5f0..b9b54ebb7 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -735,10 +735,6 @@ def _send_group_coordinator_request(self): if node_id is None: return Future().failure(Errors.NodeNotReadyError('coordinator')) - elif not self._client.ready(node_id, metadata_priority=False): - e = Errors.NodeNotReadyError(node_id) - return Future().failure(e) - max_version = 3 request = FindCoordinatorRequest( key=self.group_id,