Select on sockets to avoid busy polling during bootstrapbootstrap_select

1 files changed, 2 insertions, 0 deletions

diff --git a/kafka/client_async.py b/kafka/client_async.py
index 5308c1f..ecd2cea 100644
--- a/kafka/client_async.py
+++ b/kafka/client_async.py
@@ -245,12 +245,14 @@ class KafkaClient(object):
                                          **self.config)
             bootstrap.connect()
             while bootstrap.connecting():
+                self._selector.select(1)
                 bootstrap.connect()
             if not bootstrap.connected():
                 bootstrap.close()
                 continue
             future = bootstrap.send(metadata_request)
             while not future.is_done:
+                self._selector.select(1)
                 bootstrap.recv()
             if future.failed():
                 bootstrap.close()