如何在kafka中找到分配给哪个主题分区的消费者？

我正在构建一个kafka管理器工具,我需要检查哪个主题分区分配给一个使用者组中的哪个使用者.

假设存在具有n个分区的消费者群组-A消费主题-A,因此在不同VM中托管的群组A中可以有多个消费者.那么如何找到哪个分区被分配给哪个消费者主机？在kafka 0.9.1中有可能吗？

提前致谢.

解决方法:

您可以查看$KAFKA_HOME / bin / kafka-consumer-groups.sh如何工作并将其实现集成到您的kafka管理器工具中,此工具将向您显示详细的组所有者信息(例如,分区分配,滞后,IP).

GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG OWNER
 page_visits_10k 0 500 3333 2833 consumer-1_ / 10.139.176.190
 page_visits_10k 1 0 3334 3334 consumer-1_ / 10.139.176.190
 page_visits_10k 2 0 3333 3333 consumer-1_ / 10.139.176.190

标签：java,apache-zookeeper,apache-kafka,kafka-consumer-api
来源： https://codeday.me/bug/20190519/1134525.html