|
对于最新稳定版本,请使用 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处理监听器不支持非阻塞重试。 |
| 非阻塞重试不能与容器交易合并。 |