|
|
@ -149,6 +149,7 @@ public class KafkaAutoConfiguration {
|
|
|
|
@Bean
|
|
|
|
@Bean
|
|
|
|
@ConditionalOnProperty(name = "spring.kafka.retry.topic.enabled")
|
|
|
|
@ConditionalOnProperty(name = "spring.kafka.retry.topic.enabled")
|
|
|
|
@ConditionalOnSingleCandidate(KafkaTemplate.class)
|
|
|
|
@ConditionalOnSingleCandidate(KafkaTemplate.class)
|
|
|
|
|
|
|
|
@SuppressWarnings("deprecation")
|
|
|
|
public RetryTopicConfiguration kafkaRetryTopicConfiguration(KafkaTemplate<?, ?> kafkaTemplate) {
|
|
|
|
public RetryTopicConfiguration kafkaRetryTopicConfiguration(KafkaTemplate<?, ?> kafkaTemplate) {
|
|
|
|
KafkaProperties.Retry.Topic retryTopic = this.properties.getRetry().getTopic();
|
|
|
|
KafkaProperties.Retry.Topic retryTopic = this.properties.getRetry().getTopic();
|
|
|
|
RetryTopicConfigurationBuilder builder = RetryTopicConfigurationBuilder.newInstance()
|
|
|
|
RetryTopicConfigurationBuilder builder = RetryTopicConfigurationBuilder.newInstance()
|
|
|
|