手动提交偏移量

通常，当使用 AckMode.MANUAL 或 AckMode.MANUAL_IMMEDIATE 时，确认必须按顺序进行，因为 Kafka 不为每条记录维护状态，只为每个组/分区维护一个已提交的偏移量。从 2.8 版本开始，您现在可以设置容器属性 asyncAcks，它允许按任意顺序确认轮询返回的记录。侦听器容器将推迟乱序提交，直到收到缺少的确认。消费者将暂停（不发送新记录），直到前一次轮询的所有偏移量都已提交。