Do not log topic-specific errors in full metadata fetch (#1980)

dpkp · Dec 30, 2019 · 46882a8 · 46882a8
1 parent 2a86b23
commit 46882a8
Showing 1 changed file with 4 additions and 0 deletions.
diff --git 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)