diff options
| author | Michael Smith <mlrsmith@gmail.com> | 2016-06-17 14:24:00 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-06-17 14:24:00 -0700 |
| commit | 5b9c55817b76eab8346f65e7c973c518d1e82409 (patch) | |
| tree | 82e9a6627f2a666b1866a236f42a12e3c7740d19 | |
| parent | 1e532c674067e2399fa014151a2e8e49caa4fe58 (diff) | |
| download | kafka-python-5b9c55817b76eab8346f65e7c973c518d1e82409.tar.gz | |
Close selector when closing the client connection to fix fd leak. (#729)
| -rw-r--r-- | kafka/client_async.py | 1 |
1 files changed, 1 insertions, 0 deletions
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: |