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);
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