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

dpkp · dpkp · commit bd0caa76d0ce · 2016-02-15T16:21:45.000-08:00
diff --git a/kafka/cluster.py b/kafka/cluster.py
@@ -143,8 +143,8 @@ def update_metadata(self, metadata):
                             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:
