From 72fa7ef4fdb5be215aab7a075ad2257acbb059aa Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Thu, 18 Feb 2016 21:48:39 -0800
Subject: More friendly warning when offset fetch request returns unknown topic
 / partition

---
 kafka/coordinator/consumer.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/kafka/coordinator/consumer.py b/kafka/coordinator/consumer.py
index b3ff56d..97e8a99 100644
--- a/kafka/coordinator/consumer.py
+++ b/kafka/coordinator/consumer.py
@@ -612,7 +612,8 @@ class ConsumerCoordinator(BaseCoordinator):
                         self._subscription.mark_for_reassignment()
                         future.failure(error)
                     elif error_type is Errors.UnknownTopicOrPartitionError:
-                        log.warning("OffsetFetchRequest -- unknown topic %s",
+                        log.warning("OffsetFetchRequest -- unknown topic %s"
+                                    " (have you committed any offsets yet?)",
                                     topic)
                         continue
                     else:
-- 
cgit v1.2.1