diff options
| author | Dana Powers <dana.powers@gmail.com> | 2019-09-30 07:49:59 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2019-09-30 07:49:59 -0700 |
| commit | 87fb1bb48f82bcaa6c5e1a1edadab2832659801c (patch) | |
| tree | 86a2de52a2cfb85ecad0dcc1a9c3a8c49a5e0f26 /kafka/consumer/group.py | |
| parent | 7a7a890d7f50327d17358559d769e26b5268167e (diff) | |
| download | kafka-python-87fb1bb48f82bcaa6c5e1a1edadab2832659801c.tar.gz | |
Improve/refactor bootstrap_connected
Diffstat (limited to 'kafka/consumer/group.py')
| -rw-r--r-- | kafka/consumer/group.py | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index a55bec1..15c2905 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -393,9 +393,7 @@ class KafkaConsumer(six.Iterator): def bootstrap_connected(self): """Return True if the bootstrap is connected.""" - if self._client._bootstrap_fails > 0: - return False - return True + return self._client.bootstrap_connected() def assign(self, partitions): """Manually assign a list of TopicPartitions to this consumer. |