Kafka-python 检索主题列表

Posted 2023-03-10

【中文标题】Kafka-python 检索主题列表

【英文标题】：Kafka-python retrieve the list of topics

【发布时间】：2016-08-07 02:35:58

【问题描述】：

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

类似这样的：

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

【问题讨论】：

你试过kafka-python.readthedocs.org/en/1.0.2/apidoc/…吗？

非常感谢，这正是我想要的。如果您想写一个答案，我会将其标记为正确。也许对其他人也有用。

【参考方案1】：

试试KafkaConsumer.topics()的方法。

【讨论】：

这似乎没有轮询 Kafka 的可用主题，仅列出消费者实例订阅的主题。

这不是一个静态方法，所以必须创建一个KafkaConsumer的实例才能使用它，但事实证明你可以在没有主题列表的情况下这样做，它实际上会列出来自kafka的主题

【参考方案2】：

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

【讨论】：

听起来不错，不起作用 "ValueError: 主题名称 "*" 是非法的，它包含除 ASCII 字母数字、"."、"_" 和 "-"" 以外的字符