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