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