JavaShuo
kafka重置offset
时间 2019-11-13
标签
kafka
重置
offset
kafka重置offset
1.删除zookeeper上节点信息
打开client :./zkCli.sh -server 127.0.0.1:12181
删除consumer:rmr /consumers/xxx
2.代码中设置从最小读
(注意程序启动前保证zk上的consumer不存在)
props.put("auto.offset.reset", "smallest");