作为 Kafka 0.10 是不是不再使用zookeeper来存储滞后，我现在如何检索它？有没有办法从消费者那里获得它？
Kafka 0.10
piv4azn71#
根据最新的文档：kafka.apache.org/documentation，它是通过以下方式完成的：
> bin/kafka-consumer-groups.sh --bootstrap-server broker1:9092 --describe --group test-consumer-group TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID test-foo 0 1 3 2 consumer-1-a5d61779-4d04-4c50-a6d6-fb35d942642d /127.0.0.1 consumer-1
bis0qfac2#
基于分区求和您也可以使用以下命令对计数求和：bin/kafka-consumer-groups.sh-引导服务器kafka-server:9092 -description-group consumer group name | awk'{sum+=$5}结束{print sum}'
hfyxw5xn3#
Kafka0.10.0.x：
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group your_consumer_group
Kafka0.9或更低版本：
bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper localhost:2181 --group your_consumer_group --topic your_topic
3条答案
按热度按时间piv4azn71#
根据最新的文档：kafka.apache.org/documentation，它是通过以下方式完成的：
bis0qfac2#
基于分区求和您也可以使用以下命令对计数求和：
bin/kafka-consumer-groups.sh-引导服务器kafka-server:9092 -description-group consumer group name | awk'{sum+=$5}结束{print sum}'
hfyxw5xn3#
Kafka0.10.0.x：
Kafka0.9或更低版本：