我正在Kafka与Spark流在斯卡拉工作。我需要从多个主题获取消息。为此，我需要输入每个主题的消费者组。
我尝试了以下命令：
bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group group_name为此，我需要提到消费者群体，并检查我的主题是否属于这个群体。但我不知道消费者群体对某些主题的价值。
那么，是否有任何命令或编程方式来查找给定主题的使用者组？
在此方面的任何帮助都将不胜感激。谢谢您
我正在Kafka与Spark流在斯卡拉工作。我需要从多个主题获取消息。为此，我需要输入每个主题的消费者组。
我尝试了以下命令：
bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group group_name为此，我需要提到消费者群体，并检查我的主题是否属于这个群体。但我不知道消费者群体对某些主题的价值。
那么，是否有任何命令或编程方式来查找给定主题的使用者组？
在此方面的任何帮助都将不胜感激。谢谢您
3条答案
按热度按时间inb24sb21#
通过指定主题，可以从各种主题中读取数据。你可以简单地创建一个主题Map。请参阅下面的链接
https://www.tutorialspoint.com/apache_kafka/apache_kafka_consumer_group_example.htm
s2j5cfk02#
它需要一些时间，因为它会检查所有的主题，但会告诉哪些消费者群体使用该主题。
but5z9lq3#
kafka没有提供命令/api来列出从指定主题消费的消费者组。相反，您可以使用yahoo开发的工具来管理kafka集群：yahoo kafka管理器。安装此软件并将yahoo kafka manager指向您的kafka群集后，您可以从指定主题查看消费群体。