最近有一个业务找到我说,他们要对某一个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

上面是最大的位置在那边