手动提交偏移量

Doubao 中英对照 Manually Committing Offsets

通常，在使用 AckMode.MANUAL 或 AckMode.MANUAL_IMMEDIATE 时，确认必须按顺序进行，因为 Kafka 不为每条记录维护状态，而只为每个 group/partition 维护一个已提交的偏移量。从版本 2.8 开始，你现在可以设置容器属性 asyncAcks，这使得为 poll 返回的记录所做的确认可以按任意顺序进行确认。监听器容器会延迟乱序提交，直到收到缺失的确认为止。Consumer 将被暂停（不投递新记录），直到上一次 poll 的所有偏移量都已提交。

important

虽然此特性允许应用程序异步处理记录，但应当理解，它会增加失败后重复投递的可能性。

important

当激活 asyncAcks 时，在提交偏移量时不能使用 nack()（负向确认）。