From 5975de8b79c88afe0a3bacab24d469413ad12b86 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sat, 9 Jan 2016 13:39:05 -0800 Subject: Refresh metadata on failed connection attempts --- kafka/client_async.py | 5 +++++ 1 file changed, 5 insertions(+) (limited to 'kafka/client_async.py') 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): -- cgit v1.2.1