|
|
@ -162,7 +162,7 @@ public class KafkaAutoConfiguration {
|
|
|
|
KafkaProperties.Retry.Topic retryTopic = this.properties.getRetry().getTopic();
|
|
|
|
KafkaProperties.Retry.Topic retryTopic = this.properties.getRetry().getTopic();
|
|
|
|
RetryTopicConfigurationBuilder builder = RetryTopicConfigurationBuilder.newInstance()
|
|
|
|
RetryTopicConfigurationBuilder builder = RetryTopicConfigurationBuilder.newInstance()
|
|
|
|
.maxAttempts(retryTopic.getAttempts())
|
|
|
|
.maxAttempts(retryTopic.getAttempts())
|
|
|
|
.useSingleTopicForFixedDelays()
|
|
|
|
.useSingleTopicForSameIntervals()
|
|
|
|
.suffixTopicsWithIndexValues()
|
|
|
|
.suffixTopicsWithIndexValues()
|
|
|
|
.doNotAutoCreateRetryTopics();
|
|
|
|
.doNotAutoCreateRetryTopics();
|
|
|
|
setBackOffPolicy(builder, retryTopic);
|
|
|
|
setBackOffPolicy(builder, retryTopic);
|
|
|
|