java - Apache 卡夫卡 : How to find out consumer group of a topic?

Question

我正在 Scala 中使用 Spark 流处理 Kafka。我需要从多个主题中获取消息。为此，我需要输入每个主题的消费者组。

我尝试过以下命令:

bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group group_name

为此，我需要提及消费者组并检查我的主题是否属于该组。但我不知道某些主题的消费者群体值(value)。

那么，是否有任何命令或编程方式来查找给定主题的消费者群体？

对此的任何帮助将不胜感激。谢谢

Answer 1

for i in `kafka-consumer-groups --list --bootstrap-server localhost:9092`; do echo $i; (kafka-consumer-groups --describe --bootstrap-server localhost:9092 --group $i 2>&1| grep mytopic); done

这需要一些时间，因为它会检查所有主题，但会告诉哪些消费者组使用该主题。