kafka手动设置offset

标签：too   class   offset   set   需求   --   手动   最大   tools   

项目中经常有需求不是消费kafka队列全部的数据，取区间数据

查询kafka最大的offset: ./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 192.168.1.4:9092 --topic zhangyi --time -1

查询kafka最小的offset: ./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 192.168.1.4:9092 --topic zhangyi --time -2

kafka手动设置offset

标签：too   class   offset   set   需求   --   手动   最大   tools   

原文地址：https://www.cnblogs.com/masterZ/p/12257186.html