diff options
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. |