kafka查询topic 已经失效的日志offset位置和最新的offset位置
最近有一个业务找到我说,他们要对某一个topic进行重新消费,最多能消费几天前的数据,我虽然在kafka那边设置了topic最长有效期72小时,但是具体是可消费的日志是从哪个数据到那个值我还是不知道的,查了资料有下面两个命令
/usr/local/kafka/bin/kafka-run-class.sh kafka.tools.GetOffsetShell --topic mytopic --time -2 --broker-list 10.10.23.17:9092
mytopic:0:11385
mytopic:1:11749
mytopic:2:11396
mytopic:3:11434
mytopic:4:11693
上面是未失效的offset位置
/usr/local/kafka/bin/kafka-run-class.sh kafka.tools.GetOffsetShell --topic mytopic --time -1 --broker-list 10.10.23.17:9092
mytopic:0:18365
mytopic:1:18182
mytopic:2:17685
mytopic:3:17789
mytopic:4:18278
上面是最大的位置在那边
暂无标签
用手机扫描下方二维码可在手机上浏览和分享
评论功能已关闭