手动提交偏移量

通常,使用AckMode.MANUALAckMode.MANUAL_IMMEDIATE,确认必须按顺序确认,因为卡夫卡不为每条记录保持状态,只为每个组/分区保留已提交的偏移量。 从2.8版本开始,你现在可以设置容器属性异步加速允许对投票返回的记录的致谢以任意顺序被确认。 监听器容器会推迟顺序错误的提交,直到收到缺失的确认。 消费者将被暂停(无新记录交付),直到上一次投票的所有偏移量都提交完毕。spring-doc.cadn.net.cn

虽然此功能允许应用程序异步处理记录,但应理解它增加了故障后重复交付的可能性。
什么时候异步加速激活时,无法使用Nack()(否定确认)在提交抵消时