查看kafka偏移量

kafka生产最大位置偏移量查看 进入kafka的bin目录bash cd /opt/cloudera/parcels/KAFKA-3.0.0-1.3.0.0.p0.40/lib/kafka/bin 查询 topic 为 normal-tollgate  的每一个Partition 的生产消息的最大偏移位置code ./kafka-run-class.sh kafka.tools.GetOffse

>>阅读原文<<