kafka生产最大位置偏移量查看

进入kafka的bin目录

 cd /opt/cloudera/parcels/KAFKA-3.0.0-1.3.0.0.p0.40/lib/kafka/bin

查询 topic 为 normal-tollgate 的每个Partition 的生产消息的最大偏移位置

./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list cdh6:9092 --topic normal-tollgate --time -1

查看kafka偏移量

zookeeper查看kafka消费偏移量

进入zookeeper的根目录

 cd /opt/cloudera/parcels/CDH-5.12.0-1.cdh5.12.0.p0.29/lib/zookeeper/bin/

./zkCli.sh

如下图129就是kettleFromkafka这个消费者组在 topic temp 的Partition为0 的消费偏移量

查看kafka偏移量