Skip to content

Commit 46882a8

Browse files
authored
Do not log topic-specific errors in full metadata fetch (#1980)
1 parent 2a86b23 commit 46882a8

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

kafka/cluster.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -285,6 +285,10 @@ def update_metadata(self, metadata):
285285
_new_broker_partitions[leader].add(
286286
TopicPartition(topic, partition))
287287

288+
# Specific topic errors can be ignored if this is a full metadata fetch
289+
elif self.need_all_topic_metadata:
290+
continue
291+
288292
elif error_type is Errors.LeaderNotAvailableError:
289293
log.warning("Topic %s is not available during auto-create"
290294
" initialization", topic)

0 commit comments

Comments
 (0)