|
对于最新稳定版本,请使用 Spring for Apache Kafka 4.0.0! |
非阻塞重试
2.9 版本改变了启动基础设施豆的机制;参见配置,了解当前启动该功能的两个机制。
在 Kafka 中实现非阻塞重试/DLT 功能通常需要设置额外主题,并创建和配置相应的监听器。
自2.7版本起,Spring for Apache Kafka通过以下语言支持该功能@RetryableTopic注释和RetryTopicConfiguration用类简化了自助过程。
自 3.2 版本起,Spring for Apache Kafka 支持在类上进行非阻塞重试,@KafkaListener
| Batch处理监听器不支持非阻塞重试。 |
| 非阻塞重试不能与容器交易合并。 |