From 05b06bf5243fafca8d91ffc72e78c1ac2ffcfbfe Mon Sep 17 00:00:00 2001 From: bsko98 Date: Fri, 20 Feb 2026 15:25:04 +0900 Subject: [PATCH 1/2] =?UTF-8?q?chore:=ED=84=B0=EB=AF=B8=EB=84=90=20?= =?UTF-8?q?=ED=85=8C=EC=8A=A4=ED=8A=B8=EB=A5=BC=20=EC=9C=84=ED=95=B4=20?= =?UTF-8?q?=EC=84=A4=EC=A0=95=20=EC=B6=94=EA=B0=80(=ED=97=A4=EB=8D=94=20?= =?UTF-8?q?=EB=AC=B4=EC=8B=9C)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/resources/application.yml | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index 4f5803a0..cf883830 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -209,6 +209,8 @@ spring: value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer properties: spring.json.trusted.packages: "*" + spring.json.use.type.headers: false + spring.json.value.default.type: until.the.eternity.dcs.common.kafka.TestDTO logging: level: root: INFO From ed9a20dc850c5c232158a811ac6a477600ae5c1c Mon Sep 17 00:00:00 2001 From: bsko98 Date: Fri, 20 Feb 2026 15:26:25 +0900 Subject: [PATCH 2/2] =?UTF-8?q?chore:=ED=84=B0=EB=AF=B8=EB=84=90=20?= =?UTF-8?q?=ED=85=8C=EC=8A=A4=ED=8A=B8=EB=A5=BC=20=EC=9C=84=ED=95=B4=20?= =?UTF-8?q?=ED=86=A0=ED=94=BD=20=EB=B3=80=EA=B2=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../the/eternity/dcs/common/kafka/KafkaConsumerService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/until/the/eternity/dcs/common/kafka/KafkaConsumerService.java b/src/main/java/until/the/eternity/dcs/common/kafka/KafkaConsumerService.java index bacc584d..8bc2e9c6 100644 --- a/src/main/java/until/the/eternity/dcs/common/kafka/KafkaConsumerService.java +++ b/src/main/java/until/the/eternity/dcs/common/kafka/KafkaConsumerService.java @@ -7,7 +7,7 @@ @Service @Slf4j public class KafkaConsumerService { - @KafkaListener(topics = "test-topic", groupId = "devnogi-community-group") + @KafkaListener(topics = "test2", groupId = "devnogi-community-group") public void consume(TestDTO message) { log.info("컨수머 테스트 시작"); log.info("🎉 Kafka로부터 받은 메시지: {}", message);