feat: Outbox 이벤트 저장을 위한 Kafka 이벤트 리스너 수정

Author: rnqhstmd

apps/commerce-api/src/main/java/com/loopers/interfaces/api/listener/ProductLikeEventListener.java

@@ -1,10 +1,11 @@
 package com.loopers.interfaces.api.listener;
 
 import com.loopers.domain.like.LikeEvent;
-import com.loopers.infrastructure.kafka.producer.LikeChangedEventProducer;
+import com.loopers.domain.outbox.OutboxService;
+import com.loopers.infrastructure.kafka.dto.LikeChangedDto;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.scheduling.annotation.Async;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.event.TransactionPhase;
 import org.springframework.transaction.event.TransactionalEventListener;
@@ -14,23 +15,33 @@
 @RequiredArgsConstructor
 public class ProductLikeEventListener {
 
-    private final LikeChangedEventProducer likeChangedEventProducer;
+    private final OutboxService outboxService;
 
-    @Async
-    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
-    public void handleLikeChangedKafkaEvent(LikeEvent event) {
-        log.debug("좋아요 Kafka 이벤트 발행 시작: productId={}, action={}",
+    @Value("${kafka.topic.product-like-name}")
+    private String productLikeTopic;
+
+    @TransactionalEventListener(phase = TransactionPhase.BEFORE_COMMIT)
+    public void handleLikeChangedOutboxEvent(LikeEvent event) {
+        log.debug("좋아요 Outbox 이벤트 저장: productId={}, action={}",
                 event.productId(), event.action());
 
-        try {
-            String likeType = switch (event.action()) {
-                case ADDED -> "LIKED";
-                case REMOVED -> "UNLIKED";
-            };
+        String likeType = switch (event.action()) {
+            case ADDED -> "LIKED";
+            case REMOVED -> "UNLIKED";
+        };
+
+        LikeChangedDto payload = LikeChangedDto.of(
+                event.productId(),
+                likeType
+        );
 
-            likeChangedEventProducer.sendLikeChangedEvent(event.productId(), likeType);
-        } catch (Exception e) {
-            log.error("좋아요 Kafka 이벤트 발행 실패: productId={}", event.productId(), e);
-        }
+        outboxService.saveEvent(
+                "PRODUCT",
+                event.productId().toString(),
+                "LIKE_CHANGED",
+                productLikeTopic,
+                event.productId().toString(),
+                payload
+        );
     }
 }