From 2ddad382fe37e010f4fc43e6be33db83b0b64aea Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Fri, 3 Mar 2017 12:12:17 -0800
Subject: Mark last_attempt time during connection close to fix blackout
 calculation

---
 kafka/conn.py | 1 +
 1 file changed, 1 insertion(+)

(limited to 'kafka/conn.py')

diff --git a/kafka/conn.py b/kafka/conn.py
index ae3c55d..a040439 100644
--- 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
-- 
cgit v1.2.1