使用 Kafka-Python 在 Kafka 中查找消费者组下的主题答案

【问题标题】：Find the topics under a consumer group in Kafka using Kafka-Python使用 Kafka-Python 在 Kafka 中查找消费者组下的主题
【发布时间】：2020-05-07 00:59:22
【问题描述】：

我的 python 脚本的输入是消费者组的名称，输出应该是消费者组下的主题列表。
我的代码目前不返回当前偏移量为 -1 的主题。
有没有更好的方法，我可以通过Kafka-python获取消费者组下所有主题的列表。
我实际上正在寻找使用 Kafka 工具替换组 cmd 中的描述主题。

from kafka import KafkaAdminClient
topics_in_groups = {};
client = KafkaAdminClient(bootstrap_server='localhost:9092')
for group in client.list_consumer_groups():
  topics_in_groups[group[0]] = [];
  topic_dict = client.list_consumer_group_offsets(group[0]);
  for topic in topic_dict:
    topics_in_groups[group[0]].append(topic.topic)

【问题讨论】：

标签： apache-kafka python-3.7 kafka-python

【解决方案1】：

client.list_consumer_group_offsets(group[0]) 将为您获取消费者组的元数据，下面的代码将为您提供组的主题和分区列表。

topics_in_groups = []
for topic,prtitions in topic_dict:
    topics_in_groups.append({"topic":topic, "partition": partition})

【讨论】：