此版本仍在开发中,尚不被认为是稳定的。对于最新的稳定版本,请使用 Spring for Apache Kafka 3.3.9spring-doc.cadn.net.cn

非阻塞重试

2.9 版更改了引导基础设施 Bean 的机制;请参阅配置,了解现在引导该功能所需的两种机制。spring-doc.cadn.net.cn

使用 Kafka 实现非阻塞重试 / dlt 功能通常需要设置额外的主题并创建和配置相应的监听器。 从 2.7 开始,Spring for Apache Kafka 通过@RetryableTopicannotation 和RetryTopicConfiguration类来简化引导。spring-doc.cadn.net.cn

从 3.2 开始,Spring for Apache Kafka 支持在类上使用 @KafkaListener 进行非阻塞重试。spring-doc.cadn.net.cn

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