From 874e7e0aad61f4f86b90f91fc266c9e240891a29 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Sun, 29 Dec 2019 12:15:53 -0800
Subject: Do not log topic-specific errors in full metadata fetch

---
 kafka/cluster.py | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/kafka/cluster.py b/kafka/cluster.py
index 19137de..438baf2 100644
--- a/kafka/cluster.py
+++ b/kafka/cluster.py
@@ -285,6 +285,10 @@ class ClusterMetadata(object):
                         _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)
-- 
cgit v1.2.1