diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-01-10 09:30:06 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-01-10 09:30:06 -0800 |
| commit | 0a62cc1b862efb884b4e7f72ff3254763941fb04 (patch) | |
| tree | 82260366b391e2970be1348410aba5e8f1b3d08a /kafka/client_async.py | |
| parent | b7104957f7294d3cb0e47d47ff1b6710acf5653e (diff) | |
| parent | 5975de8b79c88afe0a3bacab24d469413ad12b86 (diff) | |
| download | kafka-python-0a62cc1b862efb884b4e7f72ff3254763941fb04.tar.gz | |
Merge pull request #499 from dpkp/handle_disconnect
Refresh metadata on failed connection attempts
Diffstat (limited to 'kafka/client_async.py')
| -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): |