Confluent-Kafka Python：如何以编程方式列出所有主题答案

【问题标题】：Confluent-Kafka Python : How to list all topics programmaticallyConfluent-Kafka Python：如何以编程方式列出所有主题
【发布时间】：2019-09-23 20:06:01
【问题描述】：

我的本地系统中运行着一个 kafka 代理。为了使用基于 Django 的 Web 应用程序与损坏的人进行通信，我使用了 confluent-kafka 包装器。但是，通过浏览 admin api，我找不到任何列出 kafka 主题的 api。（主题是务实的，是动态的）。

有什么方法可以在我的程序中列出它们？要求是，如果我的工作人员重新启动所有分配的听这些主题的消费者，则必须重新初始化，所以我想循环到所有主题并为每个主题分配一个消费者。

【问题讨论】：

标签： python django python-3.x apache-kafka confluent-platform

【解决方案1】：

这是怎么做的：

>>> from confluent_kafka.admin import AdminClient

>>> conf = {'bootstrap.servers': 'vps01:9092,vps02:9092,vps03:9092'}
>>> kadmin = AdminClient(conf)

>>> kadmin.list_topics().topics # Returns a dict(). See example below.
{'topic01': TopicMetadata(topic01, 3 partitions),}

希望对你有帮助。

【讨论】：

【解决方案2】：

尝试再次搜索list_topics

https://docs.confluent.io/5.2.1/clients/confluent-kafka-python/index.html#confluent_kafka.Consumer.list_topics

https://docs.confluent.io/5.2.1/clients/confluent-kafka-python/index.html#confluent_kafka.Producer.list_topics

【讨论】：