fix: SSE 커넥션 풀 수정

- 레디스 연결을 끊음

Author: HYEONSIKOH

src/main/java/org/dfbf/soundlink/domain/alert/service/AlertService.java

@@ -80,6 +80,7 @@ public SseEmitter connectAlarm(Long id, String lastEventId) {
         sseEmitter.onTimeout(() -> alertRepository.delete(id, emitterId));     // 타임아웃 시 처리
 
         try {
+            log.info("아아 알림 테스트 {}", emitterId);
             sseEmitter.send(SseEmitter.event()
                     .id(this.createEmitterId(id))
                     .name("open")
@@ -116,6 +117,7 @@ public void send(Long userId, String alertName, Object data) {
             ObjectMapper objectMapper = new ObjectMapper();
             String jsonMsg = objectMapper.writeValueAsString(data); // msg를 JSON 문자열로 변환
 
+            log.info("아아 알림 테스트 {}", emitterId);
             sseEmitter.send(
                     SseEmitter.event()
                             .id(eventId)

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

@@ -38,7 +38,8 @@ public void updateQty(String kafkaMessage) {
             if (alertRepository.getEmitterId(alert.getUserId()).isPresent()) {
                 alertService.send(alert.getUserId(), alert.getType(), alert.getData());
             } else {
-                redisTemplate.opsForValue().set("alert:" + alert.getEventId(), alert, 10, TimeUnit.MINUTES);
+                //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());