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

Question

我是 kafka 世界的新手，正在尝试为 python

中的 kafka 消费者执行以下操作

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])