From 20f21c3281bad5243f69425e577cdef5d2b52344 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Thu, 8 Mar 2018 13:15:47 -0500 Subject: Close leaked selector in version check --- kafka/conn.py | 1 + 1 file changed, 1 insertion(+) diff --git a/kafka/conn.py b/kafka/conn.py index d778c31..67ff194 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -919,6 +919,7 @@ class BrokerConnection(object): for response, future in self.recv(): future.success(response) selector.select(1) + selector.close() if f.succeeded(): if isinstance(request, ApiVersionRequest[0]): -- cgit v1.2.1