diff options
Diffstat (limited to 'kafka/client_async.py')
| -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: |