Merge pull request #339 from Parsely/fix-print-topics

Load all topic values on values method.
Parsely · Nov 10, 2015 · da5cada · da5cada
2 parents 74a0422 + 0fdee90
commit da5cada
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pykafka/cluster.py b/pykafka/cluster.py
@@ -44,6 +44,9 @@ def __init__(self, cluster, exclude_internal_topics, *args, **kwargs):
         self._cluster = weakref.ref(cluster)
         self._exclude_internal_topics = exclude_internal_topics
 
+    def values(self):
+        return [self[key] for key in self]
+
     def __getitem__(self, key):
         if self._should_exclude_topic(key):
             raise KeyError("You have configured KafkaClient/Cluster to hide "