|
此版本仍在开发中，尚不被认为是稳定的。对于最新的稳定版本，请使用 Spring for Apache Kafka 3.3.9！ |
模式的工作原理
如果消息处理失败，则消息将转发到具有回退时间戳的重试主题。 然后，重试主题使用者会检查时间戳，如果时间戳不是到期的，则会暂停该主题分区的消耗。 到期时，将恢复分区消耗，并再次使用消息。 如果消息处理再次失败，则消息将被转发到下一个重试主题，并重复该模式，直到成功处理发生，或者尝试用尽，并将消息发送到死信主题（如果已配置）。
举例来说，如果您有一个“main-topic”主题，并且想要设置指数退避为 1000 毫秒的非阻塞重试，乘数为 2 次和 4 次最大尝试，它将创建 main-topic-retry-1000、main-topic-retry-2000、main-topic-retry-4000 和 main-topic-dlt 主题并配置相应的使用者。 该框架还负责创建主题以及设置和配置侦听器。
| 使用此策略，您将失去 Kafka 对该主题的排序保证。 |
您可以将AckMode您喜欢的模式，但是RECORD建议。 |
使用手册时AckMode跟asyncAcks设置为 true，则DefaultErrorHandler必须配置为seekAfterError设置为false.
从版本 2.9.10、3.0.8 开始，这将设置为false对于此类配置，无条件。
对于早期版本，有必要覆盖RetryTopicConfigurationSupport.configureCustomizers()将属性设置为false.
@Override
protected void configureCustomizers(CustomizersConfigurer customizersConfigurer) {
customizersConfigurer.customizeErrorHandler(eh -> eh.setSeekAfterError(false));
}此外，在这些版本之前，使用默认（日志记录）DLT 处理程序与任何类型的手册都不兼容AckMode，无论asyncAcks财产。