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

Question

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

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

Answer 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),}

我希望这有帮助。

编辑：这些天可能有更新的API（我不知道），但上面是我以前的做法，而且效果很好。