非阻塞重试
版本 2.9 更改了启动基础豆的机制;参见 配置 了解现在需要的两种启动该功能的机制。
实现Kafka的非阻塞重试/死信功能通常需要设置额外的主题,并创建和配置相应的监听器。
自2.7版本起,Spring for Apache Kafka通过@RetryableTopic注解和RetryTopicConfiguration类简化了这一启动过程。
自 3.2 起,Spring for Apache Kafka 支持在 @KafkaListener 作用于类 上的非阻塞重试。
| 异步重试不支持 批量监听器。 |
| 非阻塞重试无法与容器事务结合使用。 |