From 53fcc35f150f7409e3b086fbf329f8d5d1f117ef Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Thu, 2 Mar 2017 18:09:11 -0800
Subject: Fix sasl reconnect bug: auth future must be reset on close

---
 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 f4fbb93..b5ce59a 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -505,6 +505,7 @@ class BrokerConnection(object):
             self._sock.close()
             self._sock = None
         self.state = ConnectionStates.DISCONNECTED
+        self._sasl_auth_future = None
         self._receiving = False
         self._next_payload_bytes = 0
         self._rbuffer.seek(0)
-- 
cgit v1.2.1