openstack/deb-python-kafka
Code Issues Proposed changes

warn (not error) on LeaderNotAvailable - this is usually not cause for concern

Browse Source
This commit is contained in:
Dana Powers
2016-02-15 16:21:45 -08:00
parent 15b4b402ea
commit bd0caa76d0
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
kafka/cluster.py
View File

@@ -143,8 +143,8 @@ class ClusterMetadata(object):
TopicPartition(topic, partition)) TopicPartition(topic, partition))
elif error_type is Errors.LeaderNotAvailableError: elif error_type is Errors.LeaderNotAvailableError:
log.error("Topic %s is not available during auto-create" log.warning("Topic %s is not available during auto-create"
" initialization", topic) " initialization", topic)
elif error_type is Errors.UnknownTopicOrPartitionError: elif error_type is Errors.UnknownTopicOrPartitionError:
log.error("Topic %s not found in cluster metadata", topic) log.error("Topic %s not found in cluster metadata", topic)
elif error_type is Errors.TopicAuthorizationFailedError: elif error_type is Errors.TopicAuthorizationFailedError: