代码之家  ›  专栏  ›  技术社区  ›  Tomasz

卡夫卡无法正确保存偏移量

  •  2
  • Tomasz  · 技术社区  · 7 年前

    我找到了这个问题的原因,请看下面我的评论

    这是我上一个问题的下一部分:

    (Solved) Kafka 0.11.0.0 keeps reseting offset on restart

    不重复我自己的话,我只需要说,我再次遇到了卡夫卡0.11.0.0重置偏移的问题,没有任何原因。我不知道这是不是某种严重的bug,或者我是否错过了一些重要的配置条目。

    不幸的是,我不能把消费者代码放在这里,但我可以保证它正确提交,它以前工作过。

    我该怎么修?

    @编辑 我看到每个主题的leader epoch检查点文件的内容中都有这些错误的偏移量。

    更改这些文件并没有任何作用,所以问题似乎出在其他地方。

    1 回复  |  直到 7 年前
        1
  •  2
  •   Tomasz    7 年前

    这是卡夫卡0.11.0.0的错误,下载0.11.0.1来修复它。 这就是原因: https://issues.apache.org/jira/browse/KAFKA-5600