Add KafkaClient.topics property to get list of known topics

2015-06-09 09:39:29 -07:00
parent 47bc6a7095
commit 513f210ba3
1 changed files with 4 additions and 0 deletions
--- a/kafka/client.py
+++ b/kafka/client.py
@@ -306,6 +306,10 @@ class KafkaClient(object):

        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()