From 809f35feaef539b4efcd5def1d8141a93d85f7fb Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Mon, 1 Apr 2019 20:32:54 -0700
Subject: Remove close_conns

---
 kafka/client_async.py | 1 -
 1 file changed, 1 deletion(-)

diff --git a/kafka/client_async.py b/kafka/client_async.py
index eff8a2b..77efac8 100644
--- a/kafka/client_async.py
+++ b/kafka/client_async.py
@@ -261,7 +261,6 @@ class KafkaClient(object):
         return conn.disconnected() and not conn.blacked_out()
 
     def _conn_state_change(self, node_id, sock, conn):
-        close_conns = []
         with self._lock:
             if conn.connecting():
                 # SSL connections can enter this state 2x (second during Handshake)
-- 
cgit v1.2.1