diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-02-15 16:21:45 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-02-15 16:21:45 -0800 |
| commit | bd0caa76d0ce0e06abaef070f919a4d80d10faf2 (patch) | |
| tree | e20a041b57b4940a7bc26a0976856f664cbc6ca8 /kafka/cluster.py | |
| parent | 15b4b402ea0a1ce26d50ad95db9465ceb6ebc299 (diff) | |
| download | kafka-python-bd0caa76d0ce0e06abaef070f919a4d80d10faf2.tar.gz | |
warn (not error) on LeaderNotAvailable - this is usually not cause for concern
Diffstat (limited to 'kafka/cluster.py')
| -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: |