diff options
| author | Dana Powers <dana.powers@gmail.com> | 2018-01-11 14:21:01 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2018-01-11 14:21:01 -0800 |
| commit | ee224e7f08c21983f5712771d35c0eff3948632f (patch) | |
| tree | d6fdfbe3d19319d2ce0dfe2e197ced50b8b95458 | |
| parent | a69320b8e3199fa9d7cfa3947a242e699a045c3b (diff) | |
| download | kafka-python-ee224e7f08c21983f5712771d35c0eff3948632f.tar.gz | |
Honor reconnect_backoff in conn.connect()
| -rw-r--r-- | kafka/conn.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index 1243bdb..f30d987 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -278,7 +278,7 @@ class BrokerConnection(object): def connect(self): """Attempt to connect and return ConnectionState""" - if self.state is ConnectionStates.DISCONNECTED: + if self.state is ConnectionStates.DISCONNECTED and not self.blacked_out(): self.last_attempt = time.time() next_lookup = self._next_afi_host_port() if not next_lookup: |