如何找到哪个消费者分配给kafka中主题的哪个分区？
How to find which consumer is assigned to which partition of a topic in kafka?
我正在构建一个 kafka manager tool，我需要检查哪个主题分区分配给了消费者组中的哪个消费者。
假设有消费者组 group-A 使用 topic-A 和 n partitions 消费主题 topic-A，那么在 different VM's 中托管的 group-A 中可以有多个消费者。那么如何找到哪个分区分配给哪个消费者主机呢？ kafka 0.9.1可以吗？
提前致谢。
您可以检查 $KAFKA_HOME/bin/kafka-consumer-groups.sh 的工作原理并将其实现集成到您的 kafka manager tool 中，此工具将向您显示详细的组所有者信息（例如，分区分配、滞后、IP）。
组主题分区当前偏移量日志结束偏移量滞后所有者
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
我正在构建一个 kafka manager tool，我需要检查哪个主题分区分配给了消费者组中的哪个消费者。
假设有消费者组 group-A 使用 topic-A 和 n partitions 消费主题 topic-A，那么在 different VM's 中托管的 group-A 中可以有多个消费者。那么如何找到哪个分区分配给哪个消费者主机呢？ kafka 0.9.1可以吗？
提前致谢。
您可以检查 $KAFKA_HOME/bin/kafka-consumer-groups.sh 的工作原理并将其实现集成到您的 kafka manager tool 中，此工具将向您显示详细的组所有者信息（例如，分区分配、滞后、IP）。
组主题分区当前偏移量日志结束偏移量滞后所有者
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