|
该版本仍在开发中，尚未被视为稳定。对于最新稳定版本，请使用 Spring for Apache Kafka 4.0.0！ |
手动提交偏移量
通常，使用AckMode.MANUAL或AckMode.MANUAL_IMMEDIATE确认必须按顺序确认，因为 Kafka 不为每条记录保持状态，只为每个组/分区保留已提交的偏移量。从版本 2.8 开始，你可以设置容器属性异步加速，允许轮询返回的记录确认以任意顺序被确认。监听器容器会推迟错误顺序的提交，直到收到缺失的确认。消费者会被暂停（无新记录传递），直到上一次轮询的所有偏移量提交完毕。
| 虽然此功能允许应用程序异步处理记录，但应理解它增加了故障后重复交付的可能性。 |
什么时候异步加速激活时，无法使用Nack（）（否定确认）在提交抵消时。 |