diff options
Diffstat (limited to 'kafka/client.py')
| -rw-r--r-- | kafka/client.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/kafka/client.py b/kafka/client.py index 1bd8587..cf29eda 100644 --- 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() |