从kafka读取消费者抵消的工具0.9

我正在使用Kafka 0.9消费者API。我需要检查给定消费者组和主题的当前消费者偏移量，并且没有找到任何列出此信息的命令行工具。我试过以下命令：从kafka读取消费者抵消的工具0.9

bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group <group_name>

但是这并没有列出消费者，即使我有消费者正在运行/轮询。

基于Kafka 0.9 new consumer api --- how to just watch consumer offsets似乎有命令行工具，但我不知道这是否为Kafka 0.9消费者。

任何帮助，将不胜感激。

来源

2016-05-13 Deeps

我能够使用bin/kafka-consumer-offset-checker.sh --zookeeper localhost：2181 --topic --group 但似乎这已被弃用，并将在0.9.0之后的版本中删除。 – Deeps

这个工作对我来说：

bin/kafka-consumer-groups.sh --new-consumer --describe --group ta-services --bootstrap-server localhost:9092

，并给出像这样的结果：

GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER 
ta-services, modsec_logs, 0, 2, 2, 0, instance1-0_/127.0.0.1 
ta-services, modsec_logs, 1, 9, 9, 0, instance1-0_/127.0.0.1 
ta-services, modsec_logs, 2, 1, 1, 0, instance1-1_/127.0.0.1 
ta-services, modsec_logs, 3, 1, 1, 0, instance1-1_/127.0.0.1

请记住，这个命令似乎工作只有当你的消费者了并活着。一旦你停下来 - 你将不会从命令中获得任何输出。我认为这是0.9.x vs 0.8.x中这个偏移检查器的缺陷之一。我找不到在0.9版本中检查“死”消费者偏移量的方法（通过脚本，没有从_offsets ...主题手动读取数据） - 如果有人知道如何做到这一点，请发布！

来源

2016-05-14 17:16:35 Marina

从kafka读取消费者抵消的工具0.9

回答

相关问题