diff options
| author | Dana Powers <dana.powers@gmail.com> | 2019-03-06 06:44:25 -0800 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2019-03-07 16:52:04 -0800 |
| commit | 957c62d6ded7a3652e7897db20a23e070a6ad852 (patch) | |
| tree | 524d8ee0c42ddc40459aea78e3e9cd1508a14675 /kafka/coordinator/base.py | |
| parent | 23132863d0e00bd8aabc0e19c7e1822dabfb05b9 (diff) | |
| download | kafka-python-957c62d6ded7a3652e7897db20a23e070a6ad852.tar.gz | |
Move all network connection IO into KafkaClient.poll()
Diffstat (limited to 'kafka/coordinator/base.py')
| -rw-r--r-- | kafka/coordinator/base.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index 1435183..664e8d2 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -252,7 +252,7 @@ class BaseCoordinator(object): if self.config['api_version'] < (0, 8, 2): self.coordinator_id = self._client.least_loaded_node() if self.coordinator_id is not None: - self._client.ready(self.coordinator_id) + self._client.maybe_connect(self.coordinator_id) continue future = self.lookup_coordinator() @@ -686,7 +686,7 @@ class BaseCoordinator(object): self.coordinator_id = response.coordinator_id log.info("Discovered coordinator %s for group %s", self.coordinator_id, self.group_id) - self._client.ready(self.coordinator_id) + self._client.maybe_connect(self.coordinator_id) self.heartbeat.reset_timeouts() future.success(self.coordinator_id) |