美文网首页Spring系列
kafka enable.auto.commit和auto.of

kafka enable.auto.commit和auto.of

作者: knock | 来源:发表于2020-07-13 10:53 被阅读0次

    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   第一次从最后一条开始消费,重启后从提交处开始消费
    

    相关文章

      网友评论

        本文标题:kafka enable.auto.commit和auto.of

        本文链接:https://www.haomeiwen.com/subject/jvqacktx.html