使用 Spring-Kafka 3.0.10 重试TopicNamesProviderFactory

Question

我使用 Spring-Kafa 2.7 为我的 kafka 应用程序实现了非阻塞重试。我需要 DLT 的自定义主题名称，因此使用了 RetryTopicNamesProviderFactory。此版本的重试过程按预期进行。最近该应用程序已迁移到 Spring Kafka 3.0.10，现在使用默认的 DLT。看来 RetryTopicNamesProviderFactory 现在被忽略了。我发现一个帖子post声称： 在 2.9.x 及更高版本中，不再支持 RetryTopicNamesProviderFactory bean 配置。 是否有等效或替代方法来使用 Spring-Kafka 3.0.10 为可重试主题配置自定义 DLT 名称？我查看了 RetryTopicConfigurer 但我需要更改整个名称而不仅仅是后缀，所以我不相信这会起作用。

Answer 1

我认为我们可以使用RetryTopicConfigurationSupport https://docs.spring.io/spring-kafka/api/org/springframework/kafka/retrytopic/RetryTopicConfigurationSupport.html