From c6b21da23e77785d9f7ee15f59d899f91059bdd6 Mon Sep 17 00:00:00 2001 From: pricelees Date: Fri, 27 Jun 2025 14:03:26 +0900 Subject: [PATCH] =?UTF-8?q?feat:=20=EC=BB=A8=EC=8A=88=EB=A8=B8,=20?= =?UTF-8?q?=ED=94=84=EB=A1=9C=EB=93=80=EC=84=9C=EC=97=90=EC=84=9C=20?= =?UTF-8?q?=EB=AA=A8=EB=91=90=20=EC=93=B0=EC=9D=B4=EB=8A=94=20Configuratio?= =?UTF-8?q?n=20=ED=81=B4=EB=9E=98=EC=8A=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 현재는 Dead Letter Topic 프로듀서 Bean만 등록 --- .../kafka/common/CommonConfiguration.java | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) create mode 100644 src/main/java/com/sangdol/consumer/infrastructure/kafka/common/CommonConfiguration.java 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(); + } +}