diff options
| -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) |