From 4abf6f95ae29a5a23319e0d62fda30882d241654 Mon Sep 17 00:00:00 2001 From: Abhijeet Mishra Date: Tue, 7 Mar 2023 17:29:49 +0530 Subject: [PATCH] Switch to single topic for same intervals in Spring Kafka retry config See gh-34504 --- .../boot/autoconfigure/kafka/KafkaAutoConfiguration.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfiguration.java b/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfiguration.java index 2c4cf3704b..d9e09f6566 100644 --- a/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfiguration.java +++ b/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfiguration.java @@ -162,7 +162,7 @@ public class KafkaAutoConfiguration { KafkaProperties.Retry.Topic retryTopic = this.properties.getRetry().getTopic(); RetryTopicConfigurationBuilder builder = RetryTopicConfigurationBuilder.newInstance() .maxAttempts(retryTopic.getAttempts()) - .useSingleTopicForFixedDelays() + .useSingleTopicForSameIntervals() .suffixTopicsWithIndexValues() .doNotAutoCreateRetryTopics(); setBackOffPolicy(builder, retryTopic);