如何使用Spring云流kafka实现Kafka @RetryableTopic？

Question

使用@阻止kafka重试。

希望在spring-cloud-stream-binder-kafka中使用相同的实现。

我注意到卡夫卡活页夹的重试是可行的，但它并没有引入预期的延迟。

Answer 1

绑定程序不支持非阻塞主题重试机制；它仅由@KafkaListener支持。