diff options
| author | Dana Powers <dana.powers@rd.io> | 2018-03-08 13:14:11 -0500 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2018-03-08 19:46:22 -0500 |
| commit | 1baa0fa266aa8e1b90e12b3cca3fa9fd140175b2 (patch) | |
| tree | e2fad6ef805a3fd78458537d66c5180f41ef4fb0 | |
| parent | 4abdb1baea2468408c36cc983dfef1e8b8f54654 (diff) | |
| download | kafka-python-reconnect_backoff_gai.tar.gz | |
Only increase reconnect backoff if all addrinfos have been triedreconnect_backoff_gai
| -rw-r--r-- | kafka/conn.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index d778c31..ddbe042 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -629,6 +629,9 @@ class BrokerConnection(object): self._reconnect_backoff = self.config['reconnect_backoff_ms'] / 1000.0 def _update_reconnect_backoff(self): + # Do not mark as failure if there are more dns entries available to try + if len(self._gai) > 0: + return if self.config['reconnect_backoff_max_ms'] > self.config['reconnect_backoff_ms']: self._failures += 1 self._reconnect_backoff = self.config['reconnect_backoff_ms'] * 2 ** (self._failures - 1) |