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