Close selector when closing the client connection to fix fd leak. (#729)

This commit is contained in:
Michael Smith
2016-06-17 14:24:00 -07:00
committed by Dana Powers
parent 1e532c6740
commit 5b9c55817b

View File

@@ -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: