From c43452314c94f187ae94bc76c73fc60e95fbe416 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Wed, 12 Mar 2025 20:44:49 -0700 Subject: [PATCH] only mark coordinator dead if connection_delay > 0 --- kafka/coordinator/base.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index 0d4aedb88..89752bb27 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -228,7 +228,7 @@ def coordinator(self): """ if self.coordinator_id is None: return None - elif self._client.is_disconnected(self.coordinator_id): + elif self._client.is_disconnected(self.coordinator_id) and self._client.connection_delay(self.coordinator_id) > 0: self.coordinator_dead('Node Disconnected') return None else: