https://blog.csdn.net/yht874690625/article/details/88311161
首先要明确一点,当SpringBoot整合kafka后,
kafka.consumer.enable.auto.commit=false 意思是让spring自动去提交offset
kafka.consumer.enable.auto.commit=true 意识是让kafka去自动提交offset
解决办法:
在kafkaconsumer的配置类里加入以下即可:yaml文件配置不够吧,程序里面需要手动设置一下
https://blog.csdn.net/yht874690625/article/details/88311161
首先要明确一点,当SpringBoot整合kafka后,
kafka.consumer.enable.auto.commit=false 意思是让spring自动去提交offset
kafka.consumer.enable.auto.commit=true 意识是让kafka去自动提交offset
解决办法:
在kafkaconsumer的配置类里加入以下即可:yaml文件配置不够吧,程序里面需要手动设置一下