Spring Kafka 3.0.6设置stopImmediate为true的影响及未处理记录去向

当你将监听器容器的stopImmediate属性设置为true时，会触发以下关键行为：

核心停止行为 #

官方文档描述：“当容器停止时，处理完当前记录后即停止，而非处理完之前poll拉取的所有记录。”
这意味着容器收到停止指令后，会等待当前正在处理的单条记录完成处理，随后立刻停止容器，不会继续处理本次poll操作拉取到的剩余未处理记录。

剩余未处理记录的处理方式 #

对于本次poll已经从Kafka拉取到本地、但还没开始处理的剩余记录，容器不会进行任何处理，这些记录的最终状态取决于你的消费者位移提交策略：

• 如果使用自动提交位移（enable.auto.commit=true）：只要还未到自动提交的时间窗口，这些剩余记录对应的位移不会被提交。当下次消费者重启后，会从上次已提交的位移位置重新拉取这些记录，进行再次处理。
• 如果使用手动提交位移：只要你还未提交当前批次的位移，同样这些未处理记录会在消费者重启后被重新消费。

简单来说，这些剩余记录不会丢失，只是暂停了处理流程，等待下一次消费者启动后重新进入处理队列。

额外注意事项 #

• 该配置适合需要快速停止容器的场景，但可能引发重复消费问题，因此如果你的业务对重复消费敏感，需要确保业务逻辑具备幂等性。
• stopImmediate=true不会中断正在处理的记录，当前记录会被完整处理完毕，不会出现半处理的中间状态。

内容的提问来源于stack exchange，提问作者Sk Monjurul Haque