此版本仍在开发中,尚不被认为是稳定的。对于最新的稳定版本,请使用 Spring for Apache Kafka 3.3.9! |
非阻塞重试
2.9 版更改了引导基础设施 Bean 的机制;请参阅配置,了解现在引导该功能所需的两种机制。
使用 Kafka 实现非阻塞重试 / dlt 功能通常需要设置额外的主题并创建和配置相应的监听器。
从 2.7 开始,Spring for Apache Kafka 通过@RetryableTopic
annotation 和RetryTopicConfiguration
类来简化引导。
从 3.2 开始,Spring for Apache Kafka 支持在类上使用 @KafkaListener 进行非阻塞重试。
批处理侦听器不支持非阻塞重试。 |
非阻塞重试不能与容器事务结合使用。 |