diff --git a/kafka/cluster.py b/kafka/cluster.py index 19137de62..438baf29d 100644 --- a/kafka/cluster.py +++ b/kafka/cluster.py @@ -285,6 +285,10 @@ def update_metadata(self, metadata): _new_broker_partitions[leader].add( TopicPartition(topic, partition)) + # Specific topic errors can be ignored if this is a full metadata fetch + elif self.need_all_topic_metadata: + continue + elif error_type is Errors.LeaderNotAvailableError: log.warning("Topic %s is not available during auto-create" " initialization", topic)