diff options
| author | Dana Powers <dana.powers@gmail.com> | 2019-12-29 16:06:58 -0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-12-29 16:06:58 -0800 |
| commit | 46882a8aaf02ed026e5126f28293abc8fdd9b023 (patch) | |
| tree | e98b99bfd6418359415efe95004d223930e1e5f7 | |
| parent | 2a86b23f477e5ed57aa987db97d11284a37d05a0 (diff) | |
| download | kafka-python-46882a8aaf02ed026e5126f28293abc8fdd9b023.tar.gz | |
Do not log topic-specific errors in full metadata fetch (#1980)
| -rw-r--r-- | kafka/cluster.py | 4 |
1 files changed, 4 insertions, 0 deletions
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) |