对于最新的稳定版本,请使用 Spring for Apache Kafka 3.3.0spring-doc.cn

非阻塞重试

版本 2.9 更改了引导基础结构 bean 的机制;请参阅配置 了解现在引导该功能所需的两种机制。spring-doc.cn

使用 Kafka 实现非阻塞重试/DLT 功能通常需要设置额外的主题并创建和配置相应的侦听器。 从 2.7 开始,Spring for Apache Kafka 通过注解和类提供了对此的支持,以简化引导。@RetryableTopicRetryTopicConfigurationspring-doc.cn

从 3.2 开始, Spring for Apache Kafka 支持对 Class 进行非阻塞重试 @KafkaListener 。spring-doc.cn

Batch 侦听器不支持非阻塞重试。
非阻塞重试不能与容器事务结合使用。