Add KafkaClient.topics property to get list of known topics

Dana Powers · Dana Powers · commit 513f210ba347 · 2015-06-11T23:24:30.000-07:00
diff --git a/kafka/client.py b/kafka/client.py
@@ -306,6 +306,10 @@ def get_partition_ids_for_topic(self, topic):
 
         return sorted(list(self.topic_partitions[topic]))
 
+    @property
+    def topics(self):
+        return list(self.topic_partitions.keys())
+
     def ensure_topic_exists(self, topic, timeout = 30):
         start_time = time.time()
 
