Kafka-python 检索主题列表
Kafka-python retrieve the list of topics
我正在使用 kafka-python,我想知道是否有显示所有主题的方法。
像这样:
./bin/kafka-topics.sh --list --zookeeper localhost:2181
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()
我正在使用 kafka-python,我想知道是否有显示所有主题的方法。
像这样:
./bin/kafka-topics.sh --list --zookeeper localhost:2181
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()