diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-09 13:39:05 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-09 18:54:08 -0800 |
| commit | 5975de8b79c88afe0a3bacab24d469413ad12b86 (patch) | |
| tree | aacd34926c60e51e941253adb7d0f6b41c733e98 | |
| parent | 651454a074114d804fc0517dff8d5cf884284594 (diff) | |
| download | kafka-python-handle_disconnect.tar.gz | |
Refresh metadata on failed connection attemptshandle_disconnect
| -rw-r--r-- | kafka/client_async.py | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py index 54d8153..30d4d6f 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -161,6 +161,11 @@ class KafkaClient(object): elif node_id in self._connecting: log.debug("Node %s connection state is %s", node_id, state) self._connecting.remove(node_id) + + if state is ConnectionStates.DISCONNECTED: + log.warning("Node %s connect failed -- refreshing metadata", node_id) + self.cluster.request_update() + return state def ready(self, node_id): |