diff options
| -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]): |