1.查看指定topic对应分区的offset
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 183.129.218.51:9092,183.129.218.51:9093,183.129.218.51:9094 -topic app-log --time -1
2.启动kafka
./bin/kafka-server-start.sh -daemon ./config/server.properties
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 183.129.218.51:9092,183.129.218.51:9093,183.129.218.51:9094 -topic app-log --time -1
./bin/kafka-server-start.sh -daemon ./config/server.properties
本文标题:kafka包中的相关命令
本文链接:https://www.haomeiwen.com/subject/nijmgxtx.html
网友评论