fix: kafka 잠시 off

- 원인모를 에러에 의해, default 서버 kafka 잠시 off

Author: HYEONSIKOH

.gitignore

@@ -37,8 +37,10 @@ out/
 .vscode/
 
 ### yml & properties ###
-*.yml
-*.properties
+chat/**/*.yml
+default/**/*.yml
+chat/**/*.properties
+default/**/*.properties
 
 ### 폴더 추가
 default/src/main/generated

default/src/main/java/org/dfbf/soundlink/global/kafka/KafkaConsumer.java

@@ -20,29 +20,29 @@
 @RequiredArgsConstructor
 public class KafkaConsumer {
 
-    private final AlertService alertService;
-    private final AlertRepository alertRepository;
-    private final RedisTemplate<String, Object> redisTemplate;
-
-    private final ObjectMapper mapper = new ObjectMapper();
-
-    // KafkaListener annotation을 통해 메시지를 수신함
-    @KafkaListener(topics = "alert-topic", groupId = "alert-service")
-    public void updateQty(String kafkaMessage) {
-        log.info("Kafka Message: -> {}", kafkaMessage);
-
-        try {
-            Alert alert = mapper.readValue(kafkaMessage, Alert.class);
+//    private final AlertService alertService;
+//    private final AlertRepository alertRepository;
+//    private final RedisTemplate<String, Object> redisTemplate;
+//
+//    private final ObjectMapper mapper = new ObjectMapper();
+//
+//    // KafkaListener annotation을 통해 메시지를 수신함
+//    @KafkaListener(topics = "alert-topic", groupId = "alert-service")
+//    public void updateQty(String kafkaMessage) {
+//        log.info("Kafka Message: -> {}", kafkaMessage);
 //
-//            if (alertRepository.getEmitterId(alert.getUserId()).isPresent()) {
-//                log.info("알림 전송: {}", alert.getUserId());
-//                alertService.send(alert.getUserId(), alert.getType(), alert.getData());
-//            } else {
-//                //redisTemplate.opsForValue().set("alert:" + alert.getEventId(), alert, 10, TimeUnit.MINUTES);
-//                log.info("No SSE connection for user {}.", alert.getUserId());
-//            }
-        } catch (JsonProcessingException e) {
-            log.error("JSON parsing error: {}", e.getMessage());
-        }
-    }
+//        try {
+//            Alert alert = mapper.readValue(kafkaMessage, Alert.class);
+////
+////            if (alertRepository.getEmitterId(alert.getUserId()).isPresent()) {
+////                log.info("알림 전송: {}", alert.getUserId());
+////                alertService.send(alert.getUserId(), alert.getType(), alert.getData());
+////            } else {
+////                //redisTemplate.opsForValue().set("alert:" + alert.getEventId(), alert, 10, TimeUnit.MINUTES);
+////                log.info("No SSE connection for user {}.", alert.getUserId());
+////            }
+//        } catch (JsonProcessingException e) {
+//            log.error("JSON parsing error: {}", e.getMessage());
+//        }
+//    }
 }

default/src/main/java/org/dfbf/soundlink/global/kafka/KafkaProducer.java

@@ -13,21 +13,21 @@
 @RequiredArgsConstructor
 public class KafkaProducer {
 
-    private final KafkaTemplate<String, String> kafkaTemplate;
-    private final ObjectMapper mapper = new ObjectMapper();
-
-    // 주어진 주제(topic)로 OrderDto 객체를 Kafka 메시지로 전송하고, 전송한 OrderDto 객체를 반환하는 메서드
-    public Alert send(String topic, Alert alert) {
-        String jsonInstring = "";
-
-        try {
-            jsonInstring = mapper.writeValueAsString(alert); // OrderDto 객체를 JSON 문자열로 변환
-        } catch (JsonProcessingException e) {
-            log.info(e.getMessage());
-        }
-
-        kafkaTemplate.send(topic, jsonInstring); // KafkaTemplate을 사용하여 Kafka 메시지를 보냄
-
-        return alert; // 전송한 OrderDto 객체를 반환
-    }
+//    private final KafkaTemplate<String, String> kafkaTemplate;
+//    private final ObjectMapper mapper = new ObjectMapper();
+//
+//    // 주어진 주제(topic)로 OrderDto 객체를 Kafka 메시지로 전송하고, 전송한 OrderDto 객체를 반환하는 메서드
+//    public Alert send(String topic, Alert alert) {
+//        String jsonInstring = "";
+//
+//        try {
+//            jsonInstring = mapper.writeValueAsString(alert); // OrderDto 객체를 JSON 문자열로 변환
+//        } catch (JsonProcessingException e) {
+//            log.info(e.getMessage());
+//        }
+//
+//        kafkaTemplate.send(topic, jsonInstring); // KafkaTemplate을 사용하여 Kafka 메시지를 보냄
+//
+//        return alert; // 전송한 OrderDto 객체를 반환
+//    }
 }