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

Question

我正在构建一个kafka manager tool,我需要检查哪个主题分区被分配给一个消费者组中的哪个消费者.

假设有消费群group-A消费的话题topic-A有n partitions,所以可以有多个消费者group-A的托管different VM's.那么如何找到哪个分区被分配给哪个消费者主机？有可能kafka 0.9.1吗？

提前致谢.

Answer 1

您可以查看$KAFKA_HOME/bin/kafka-consumer-groups.sh工作原理并将其实现集成到您的kafka manager tool工具中,此工具将向您显示详细的组所有者信息(例如,分区分配,滞后,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