apache-kafka - 偏移量存储为Kafka时如何检查消费者偏移量？

Question

从0.8.1.1版本开始，Kafka提供了在Kafka中存储偏移量的规定，而不是Zookeeper(请参阅this)。
我无法弄清楚如何检查消耗的偏移量的详细信息，因为当前的工具仅为Zookeeper提供消费者偏移量计数检查。(我指的是this)

如果有任何工具可用来检查消费者抵销，请告知我。

Answer 1

我正在使用带有存储在kafka中的偏移量的kafka 0.8.2。该工具对我有用:

./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker 
        --topic your-topic 
        --group your-consumer-group
        --zookeeper localhost:2181

您会获得所需的所有信息:主题大小，消费者滞后，所有者。