diff options
Diffstat (limited to 'kafka/coordinator/abstract.py')
| -rw-r--r-- | kafka/coordinator/abstract.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/coordinator/abstract.py b/kafka/coordinator/abstract.py index 6790bb1..89996c8 100644 --- a/kafka/coordinator/abstract.py +++ b/kafka/coordinator/abstract.py @@ -157,7 +157,7 @@ class AbstractCoordinator(object): if self.coordinator_id is None: return True - if self._client.connection_failed(self.coordinator_id): + if self._client.is_disconnected(self.coordinator_id): self.coordinator_dead() return True |