Kafka-python检索主题列表

Question

我正在使用卡夫卡-蟒蛇，我想知道是否有一种方法可以显示所有的主题。

就像这样：

./bin/kafka-topics.sh --list --zookeeper localhost:2181

Answer 1

import kafka
consumer = kafka.KafkaConsumer(group_id='test', bootstrap_servers=['server'])
consumer.topics()

Answer 2

尝试使用KafkaConsumer.topics()方法。

Answer 3

您需要使用KafkaAdminClient，而不是KafkaConsumer

import kafka
admin_client = kafka.KafkaAdminClient(bootstrap_servers=['server'])
admin_client.list_topics()