我找到了这个问题的原因,请看下面我的评论
这是我上一个问题的下一部分:
(Solved) Kafka 0.11.0.0 keeps reseting offset on restart
不重复我自己的话,我只需要说,我再次遇到了卡夫卡0.11.0.0重置偏移的问题,没有任何原因。我不知道这是不是某种严重的bug,或者我是否错过了一些重要的配置条目。
不幸的是,我不能把消费者代码放在这里,但我可以保证它正确提交,它以前工作过。
我该怎么修?
@编辑 我看到每个主题的leader epoch检查点文件的内容中都有这些错误的偏移量。
更改这些文件并没有任何作用,所以问题似乎出在其他地方。
这是卡夫卡0.11.0.0的错误,下载0.11.0.1来修复它。 这就是原因: https://issues.apache.org/jira/browse/KAFKA-5600