kafka命令行高级命令

#--time -1 查看topic各个partition 未过期最早offset  --time -2 最后offest，根据二者差值计算存量数据

sh /usr/local/kafka9092/bin/kafka-run-class.sh kafka.tools.GetOffsetShell  --bootstrap-server xxxxx:9092 --topic __consumer_offsets  --time -1

#查看message及 key,数据落地时间

bin/kafka-console-consumer.sh --bootstrap-server node1:9092,node2:9092,node3:9092 --property print.timestamp=true --property print.key=true