Search code examples
javaspringspring-kafka

RetryTopicNamesProviderFactory with Spring-Kafka 3.0.10

I implemented a non-blocking retry for my kafka app using Spring-Kafa 2.7. I needed a custom topic name for the DLT so RetryTopicNamesProviderFactory was used. The retry process worked as expected with this version. Recently the app was migrated to Spring Kafka 3.0.10 and now the default DLT is used. It appears the RetryTopicNamesProviderFactory is ignored now. I found a post post that claims that: In 2.9.x and above the RetryTopicNamesProviderFactory bean configuration is no longer supported. Is there an equivalent or alternate method to configure a custom DLT name for retryable topic using Spring-Kafka 3.0.10 ? I looked at RetryTopicConfigurer but I need the entire name changed not just the suffix so I don't believe this will work.

Solution

  • I think we can use the RetryTopicConfigurationSupport https://docs.spring.io/spring-kafka/api/org/springframework/kafka/retrytopic/RetryTopicConfigurationSupport.html