Kafka-python 检索主题列表

Kafka-python retrieve the list of topics

我正在使用 kafka-python,我想知道是否有显示所有主题的方法。

像这样:

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

尝试方法KafkaConsumer.topics()

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

您需要使用 KafkaAdminClient,而不是 KafkaConsumer:

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