Skip to content

Commit 712a3a6

Browse files
committed
fix: SSE 커넥션 풀 수정
- 로그 수정
1 parent 785eb08 commit 712a3a6

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,9 +33,9 @@ public void updateQty(String kafkaMessage) {
3333

3434
try {
3535
Alert alert = mapper.readValue(kafkaMessage, Alert.class);
36-
log.info("Converted Alert Object: {}", alert);
3736

3837
if (alertRepository.getEmitterId(alert.getUserId()).isPresent()) {
38+
log.info("알림 전송: {}", alert.getUserId());
3939
alertService.send(alert.getUserId(), alert.getType(), alert.getData());
4040
} else {
4141
//redisTemplate.opsForValue().set("alert:" + alert.getEventId(), alert, 10, TimeUnit.MINUTES);

0 commit comments

Comments
 (0)