kafka重置offset
Posted 枫红一叶
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了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");
以上是关于kafka重置offset的主要内容，如果未能解决你的问题，请参考以下文章
华为kafka安全版重置group中的topic offset不生效问题