diff --git a/src/main/java/com/sangdol/consumer/infrastructure/kafka/common/CommonConfiguration.java b/src/main/java/com/sangdol/consumer/infrastructure/kafka/common/CommonConfiguration.java new file mode 100644 index 0000000..3fb2e32 --- /dev/null +++ b/src/main/java/com/sangdol/consumer/infrastructure/kafka/common/CommonConfiguration.java @@ -0,0 +1,18 @@ +package com.sangdol.consumer.infrastructure.kafka.common; + +import org.springframework.boot.context.properties.EnableConfigurationProperties; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +import lombok.RequiredArgsConstructor; + +@Configuration +@RequiredArgsConstructor +@EnableConfigurationProperties(KafkaProperties.class) +public class CommonConfiguration { + + @Bean + public KafkaProperties.DeadLetterTopic deadLetterTopic(KafkaProperties kafkaProperties) { + return kafkaProperties.getDeadLetterTopic(); + } +}