我在建一个 kafka manager tool 我需要检查哪个主题分区被分配给消费者组中的哪个消费者。假设存在消费者群体 group-A 消费主题 topic-A 与 n partitions ，因此在 group-A 主办地 different VM's . 那么如何找到哪个分区分配给哪个使用者主机呢？有可能吗 kafka 0.9.1 ?提前谢谢。
kafka manager tool
group-A
topic-A
n partitions
different VM's
kafka 0.9.1
e0uiprwp1#
你可以查一下 $KAFKA_HOME/bin/kafka-consumer-groups.sh 工作并将其实现集成到您的 kafka manager tool ，此工具将向您显示详细的组所有者信息（例如，分区分配、延迟、ip）。组主题分区当前偏移量日志结束偏移量滞后所有者第10k 0 500 3333 2833页消费者-1/10.139.176.190第10k 1 0 3334 3334页消费者-1/10.139.176.190第10k 2 0 3333 3333页消费者-1/10.139.176.190
$KAFKA_HOME/bin/kafka-consumer-groups.sh
1条答案
按热度按时间e0uiprwp1#
你可以查一下
$KAFKA_HOME/bin/kafka-consumer-groups.sh工作并将其实现集成到您的kafka manager tool，此工具将向您显示详细的组所有者信息（例如，分区分配、延迟、ip）。组主题分区当前偏移量日志结束偏移量滞后所有者
第10k 0 500 3333 2833页消费者-1/10.139.176.190
第10k 1 0 3334 3334页消费者-1/10.139.176.190
第10k 2 0 3333 3333页消费者-1/10.139.176.190