diff options
| -rw-r--r-- | kafka/cluster.py | 4 |
1 files changed, 2 insertions, 2 deletions
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: |