Skip to content

Commit a621bdf

Browse files
authored
Only mark coordinator dead if connection_delay > 0 (#2530)
1 parent 36287cb commit a621bdf

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka/coordinator/base.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -228,7 +228,7 @@ def coordinator(self):
228228
"""
229229
if self.coordinator_id is None:
230230
return None
231-
elif self._client.is_disconnected(self.coordinator_id):
231+
elif self._client.is_disconnected(self.coordinator_id) and self._client.connection_delay(self.coordinator_id) > 0:
232232
self.coordinator_dead('Node Disconnected')
233233
return None
234234
else:

0 commit comments

Comments
 (0)