从0.8.1.1版本中,卡夫卡提供了计提卡夫卡偏移的存储,而不是动物园管理员(见本)。我无法弄清楚如何检查所消耗补偿的细节,因为目前的工具只能提供给仅供饲养员消费者偏移计数检查。(我指的是这个)
如果有任何工具可用来检查消费者的抵销,请告知我。
I'am using kafka 0.8.2 with offsets stored in kafka. This tools works good for me:
./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --topic your-topic --group your-consumer-group --zookeeper localhost:2181
You get all informations you need: topic size, consumer lag, owner.