diff options
| author | Rômulo Rosa Furtado <romuloros@gmail.com> | 2018-04-15 22:30:21 -0300 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2018-04-15 18:30:21 -0700 |
| commit | e23676d6c03b87f14ec8992de583f673dc8a1a3e (patch) | |
| tree | 27eead349cbe9bd45b03b2da91a3f7a46c3c6ab9 | |
| parent | 6163aa3c633249c0ca7903d1b6d1ab209a927980 (diff) | |
| download | kafka-python-e23676d6c03b87f14ec8992de583f673dc8a1a3e.tar.gz | |
Improve BrokerConnection initialization (#1475)
| -rw-r--r-- | kafka/conn.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index cafc4b2..daaa234 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -949,9 +949,9 @@ class BrokerConnection(object): selector = self.config['selector']() selector.register(self._sock, selectors.EVENT_READ) while not (f.is_done and mr.is_done): + selector.select(1) for response, future in self.recv(): future.success(response) - selector.select(1) selector.close() if f.succeeded(): |