模式的工作原理

如果消息处理失败,则消息将转发到具有 back off 时间戳的重试主题。 然后,重试主题使用者会检查时间戳,如果时间戳未过期,则暂停该主题分区的消耗。 到期时,将恢复分区消耗,并再次使用消息。 如果消息处理再次失败,则消息将被转发到下一个重试主题,并重复该模式,直到处理成功或尝试用尽,并将消息发送到死信主题(如果已配置)。spring-doc.cadn.net.cn

举例来说,如果您有一个“main-topic”主题,并且想要设置具有 1000 毫秒指数退避的非阻塞重试,最大尝试次数为 2 和 4,它将创建 main-topic-retry-1000、main-topic-retry-2000、main-topic-retry-4000 和 main-topic-dlt 主题并配置相应的使用者。 该框架还负责创建主题以及设置和配置侦听器。spring-doc.cadn.net.cn

使用此策略,您将失去 Kafka 对该主题的排序保证。
您可以设置AckMode模式,但RECORD建议。

使用手册时AckModeasyncAcks设置为 true,则DefaultErrorHandler必须配置seekAfterError设置为false. 从版本 2.9.10、3.0.8 开始,这将设置为false对于此类配置,无条件地。 在早期版本中,需要覆盖RetryConfigurationSupport.configureCustomizers()method 将属性设置为false.spring-doc.cadn.net.cn

@Override
protected void configureCustomizers(CustomizersConfigurer customizersConfigurer) {
    customizersConfigurer.customizeErrorHandler(eh -> eh.setSeekAfterError(false));
}

此外,在这些版本之前,使用默认 (日志记录) DLT 处理程序与任何类型的手册都不兼容AckMode,无论asyncAcks财产。spring-doc.cadn.net.cn