From bd0caa76d0ce0e06abaef070f919a4d80d10faf2 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Mon, 15 Feb 2016 16:21:45 -0800 Subject: warn (not error) on LeaderNotAvailable - this is usually not cause for concern --- kafka/cluster.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'kafka/cluster.py') diff --git a/kafka/cluster.py b/kafka/cluster.py index 1a4d5ab..cdd81f4 100644 --- a/kafka/cluster.py +++ b/kafka/cluster.py @@ -143,8 +143,8 @@ class ClusterMetadata(object): TopicPartition(topic, partition)) elif error_type is Errors.LeaderNotAvailableError: - log.error("Topic %s is not available during auto-create" - " initialization", topic) + log.warning("Topic %s is not available during auto-create" + " initialization", topic) elif error_type is Errors.UnknownTopicOrPartitionError: log.error("Topic %s not found in cluster metadata", topic) elif error_type is Errors.TopicAuthorizationFailedError: -- cgit v1.2.1