From 5b9c55817b76eab8346f65e7c973c518d1e82409 Mon Sep 17 00:00:00 2001 From: Michael Smith Date: Fri, 17 Jun 2016 14:24:00 -0700 Subject: Close selector when closing the client connection to fix fd leak. (#729) --- kafka/client_async.py | 1 + 1 file changed, 1 insertion(+) (limited to 'kafka/client_async.py') diff --git a/kafka/client_async.py b/kafka/client_async.py index 62b0095..93094e2 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -280,6 +280,7 @@ class KafkaClient(object): conn.close() self._wake_r.close() self._wake_w.close() + self._selector.close() elif node_id in self._conns: self._conns[node_id].close() else: -- cgit v1.2.1