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