Spring系列

kafka enable.auto.commit和auto.of

2020-07-13  本文已影响0人  knock

springboot项目下

    /**
     * enable-auto-commit: false 由spring提交
     * enable-auto-commit: true  由kafka提交
     */

    /**
     * enable-auto-commit: true  相同组下  (换组 会重置数据)
     * 如果这个topic某个分区有已经提交的offset,那么无论是把auto.offset.reset=earliest还是latest,都将失效,消费者会从已经提交的offset开始消费.
     */

    /**
     * enable-auto-commit: true  相同组下 (换组 会重置数据)
     * 如果这个topic某个分区没有提交的offset,那么把auto.offset.reset=latest,将没消费的设置为提交消费,然后从最后开始消费
     * 如果这个topic某个分区没有提交的offset,那么把auto.offset.reset=earliest,从没开始消费的offset开始消费
     */

非springboot项目下

enable.auto.commit false
    auto.offset.reset earliest 第一次消费, 重启后消费  都会从第一条开始重新消费全部数据
enable.auto.commit true
    auto.offset.reset earliest 第一次消费全部数据,重启后从提交处开始消费

enable.auto.commit false
    auto.offset.reset latest  第一次,重启后会从最后一条开始消费,但没有提交,换成earliest 重新消费全部数据
enable.auto.commit true
   auto.offset.reset latest   第一次从最后一条开始消费,重启后从提交处开始消费
上一篇下一篇

猜你喜欢

热点阅读