diff options
| author | Dana Powers <dana.powers@rd.io> | 2018-03-08 13:15:47 -0500 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2018-03-08 19:55:17 -0500 |
| commit | 20f21c3281bad5243f69425e577cdef5d2b52344 (patch) | |
| tree | a656b5e10c52c8358fdc6150ebd60692f202e24d | |
| parent | 4abdb1baea2468408c36cc983dfef1e8b8f54654 (diff) | |
| download | kafka-python-selector_close.tar.gz | |
Close leaked selector in version checkselector_close
| -rw-r--r-- | kafka/conn.py | 1 |
1 files changed, 1 insertions, 0 deletions
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]): |