读取kafka的offset

2030阅读 0评论2016-09-19 mfc42d
分类:Java

格式 topic:partitionId:offset
查询最小值
 bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 127.0.0.1:9092 -topic alert2 --time -29092 
alert2:0:


查询最大值
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 127.0.0.1:9092 -topic alert2 --time -1
alert2:0:187785423
设置offset
bin/zookeeper-shell.sh 127.0.0.1:2181
set /consumers/{yourConsumerGroup}/offsets/{yourFancyTopic}/{partitionId} {newOffset}

上一篇:ubuntu mysql 修改root密码和权限
下一篇:电子邮件的长度