From 4ea295409ba7659c84f0ee0890c45bd526e5f326 Mon Sep 17 00:00:00 2001 From: Jim Lim Date: Wed, 18 Sep 2013 15:49:21 -0700 Subject: [PATCH] use more informative warning --- kafka/client.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/client.py b/kafka/client.py index 77a74ec0f..45ef33363 100644 --- 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.warn("Partition is unassigned, delay for 1s and retry") + log.warn("Partition is unassigned, delay for 1s and retry. Have you created {} on zookeeper?".format(topic)) time.sleep(1) self._load_metadata_for_topics(topic) break