对于最新的稳定版本,请使用 Spring for Apache Kafka 3.3.0! |
非阻塞重试
版本 2.9 更改了引导基础结构 bean 的机制;请参阅配置 了解现在引导该功能所需的两种机制。
使用 Kafka 实现非阻塞重试/DLT 功能通常需要设置额外的主题并创建和配置相应的侦听器。
从 2.7 开始,Spring for Apache Kafka 通过注解和类提供了对此的支持,以简化引导。@RetryableTopic
RetryTopicConfiguration
从 3.2 开始, Spring for Apache Kafka 支持对 Class 进行非阻塞重试 @KafkaListener 。
Batch 侦听器不支持非阻塞重试。 |
非阻塞重试不能与容器事务结合使用。 |