Added a function to determine if bootstrap is successfully connected (#1876)

1 files changed, 6 insertions, 0 deletions

diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py
index 231fc8a..a55bec1 100644
--- a/kafka/consumer/group.py
+++ b/kafka/consumer/group.py
@@ -391,6 +391,12 @@ class KafkaConsumer(six.Iterator):
             self._subscription.subscribe(topics=topics)
             self._client.set_topics(topics)
 
+    def bootstrap_connected(self):
+        """Return True if the bootstrap is connected."""
+        if self._client._bootstrap_fails > 0:
+            return False
+        return True
+
     def assign(self, partitions):
         """Manually assign a list of TopicPartitions to this consumer.