From 4deb96fa439f9ef0ae03a7bce479ac9cfc679966 Mon Sep 17 00:00:00 2001 From: 1223v <1223v@naver.com> Date: Wed, 30 Jul 2025 20:58:44 +0900 Subject: [PATCH] =?UTF-8?q?Fix:=20Kafka=20=EC=A3=BC=EB=AC=B8=20=EC=9D=B4?= =?UTF-8?q?=EB=B2=A4=ED=8A=B8=20=EB=B0=9C=EC=83=9D=20=EC=98=88=EC=99=B8=20?= =?UTF-8?q?=EC=88=98=EC=A0=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../readyverydemo/src/order/OrderEventProducer.java | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/readyvery/readyverydemo/src/order/OrderEventProducer.java b/src/main/java/com/readyvery/readyverydemo/src/order/OrderEventProducer.java index 582d5f2..24c0c83 100644 --- a/src/main/java/com/readyvery/readyverydemo/src/order/OrderEventProducer.java +++ b/src/main/java/com/readyvery/readyverydemo/src/order/OrderEventProducer.java @@ -6,7 +6,9 @@ import com.readyvery.readyverydemo.src.order.dto.OrderUpdateMessage; import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +@Slf4j @Service @RequiredArgsConstructor public class OrderEventProducer { @@ -14,7 +16,14 @@ public class OrderEventProducer { private final KafkaTemplate kafkaTemplate; public void sendOrderUpdate(OrderUpdateMessage message) { - // 예: "order_updates"라는 토픽 사용 - kafkaTemplate.send("order_updates", message); + try { + // Kafka로 주문 업데이트 이벤트 전송 + kafkaTemplate.send("order_updates", message); + log.info("주문 이벤트 전송 성공: {}", message); + } catch (Exception e) { + // Kafka 연결 실패 시에도 주문 처리는 계속 진행 + log.warn("Kafka 연결 실패로 주문 이벤트 전송 실패, 주문 처리는 계속 진행: {}", e.getMessage()); + log.debug("Kafka 에러 상세: ", e); + } } }