update client.py to warn about missing partitions

dpkp · Sep 18, 2013 · ec97a30 · ec97a30
1 parent f47dc10
commit ec97a30
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka/client.py b/kafka/client.py
@@ -80,7 +80,7 @@ def _load_metadata_for_topics(self, *topics):
             self.topic_partitions.pop(topic, None)
 
             if not partitions:
-                log.info("Partition is unassigned, delay for 1s and retry")
+                log.warn("Partition is unassigned, delay for 1s and retry")
                 time.sleep(1)
                 self._load_metadata_for_topics(topic)
                 break