Mark last_attempt time during connection close to fix blackout calculation (#1008)

2017-03-03 16:53:01 -08:00
parent f0061624d8
commit 46b857fbbd
1 changed files with 1 additions and 0 deletions
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -504,6 +504,7 @@ class BrokerConnection(object):
            self._sock.close()
            self._sock = None
        self.state = ConnectionStates.DISCONNECTED
+        self.last_attempt = time.time()
        self._sasl_auth_future = None
        self._receiving = False
        self._next_payload_bytes = 0