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");