diff options
| author | Dana Powers <dana.powers@gmail.com> | 2018-03-09 10:28:19 -0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-03-09 10:28:19 -0500 |
| commit | d90cf22bcf5c49b6d75cac4282d7cc2ae973651c (patch) | |
| tree | 010a5ce64b0158aeedaa8c8d321eec8c42552437 | |
| parent | ce96752c3d4ca53222aebe1f824a47865bcb3aff (diff) | |
| download | kafka-python-d90cf22bcf5c49b6d75cac4282d7cc2ae973651c.tar.gz | |
Close leaked selector in version check (#1425)
| -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 798f85a..bfaed6a 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -928,6 +928,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]): |