python - kafka python - 找到消费者尚未订阅的新 kafka 主题的正确方法是什么？

Question

我是卡夫卡世界的新手，并试图为 python 中的卡夫卡消费者做以下事情

1. 获取所有 kafka 主题的列表。
2. 获取消费者订阅的主题列表。
3. 订阅新主题（尚未订阅）。

注意：我可以使用 confluent-kafka / kafka-python 库来实现这一点。

任何帮助，将不胜感激。

Answer 1

如果你创建了你的消费者kafka-python

from kafka import KafkaConsumer

consumer = KafkaConsumer(
 bootstrap_servers = 'hostname:port',
)

您可以查看可用的主题列表

consumer.topics()

当您订阅主题时，您可以查看消费者订阅

consumer.subscription()

你可以做一个减去另一个来找到你仍然需要订阅的主题，然后你可以这样做

consumer.subscribe(topics=[list_of_topic_names])