fix(notification): kafka consumer 관련 설정 버그 픽스

notification-service/src/main/java/com/justpickup/notificationservice/global/config/KafkaConsumerConfig.java

@@ -1,6 +1,5 @@
 package com.justpickup.notificationservice.global.config;
 
-import lombok.RequiredArgsConstructor;
 import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.apache.kafka.common.serialization.StringDeserializer;
 import org.springframework.beans.factory.annotation.Value;
@@ -12,18 +11,18 @@ import org.springframework.kafka.core.ConsumerFactory;
 import org.springframework.kafka.core.DefaultKafkaConsumerFactory;
 import org.springframework.kafka.listener.DefaultErrorHandler;
 
-import java.util.*;
+import java.util.HashMap;
+import java.util.Map;
 
 @EnableKafka
-@RequiredArgsConstructor
 @Configuration
 public class KafkaConsumerConfig {
 
     @Value("${kafka.host}")
-    private final String host;
+    private String host;
 
     @Value("${kafka.port}")
-    private final String port;
+    private String port;
 
     @Bean
     public ConsumerFactory<String, String> consumerFactory() {
@@ -32,6 +31,7 @@ public class KafkaConsumerConfig {
         String ipAddress = host + ":" + port;
 
         properties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, ipAddress);
+        properties.put(ConsumerConfig.GROUP_ID_CONFIG, "consumerGroupId");
         properties.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
         properties.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
 

notification-service/src/main/resources/application.yml

@@ -40,3 +40,7 @@ logging:
 # jpa query, parameter 로그 (p6spy)
 decorator.datasource.p6spy:
   enable-logging: true
+
+kafka:
+  host: 127.0.0.1
+  port: 9092