我正在 Scala 中使用 Spark 流处理 Kafka。我需要从多个主题中获取消息。为此，我需要输入每个主题的消费者组。
我尝试过以下命令:
bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group group_name
为此，我需要提及消费者组并检查我的主题是否属于该组。但我不知道某些主题的消费者群体值(value)。
那么，是否有任何命令或编程方式来查找给定主题的消费者群体？
对此的任何帮助将不胜感激。 谢谢
最佳答案
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
这需要一些时间，因为它会检查所有主题，但会告诉哪些消费者组使用该主题。
关于java - Apache 卡夫卡 : How to find out consumer group of a topic?，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/43542485/