File tree Expand file tree Collapse file tree
src/main/java/com/readyvery/readyverydemo/src/order Expand file tree Collapse file tree Original file line number Diff line number Diff line change 66import com .readyvery .readyverydemo .src .order .dto .OrderUpdateMessage ;
77
88import lombok .RequiredArgsConstructor ;
9+ import lombok .extern .slf4j .Slf4j ;
910
11+ @ Slf4j
1012@ Service
1113@ RequiredArgsConstructor
1214public class OrderEventProducer {
1315
1416 private final KafkaTemplate <String , OrderUpdateMessage > kafkaTemplate ;
1517
1618 public void sendOrderUpdate (OrderUpdateMessage message ) {
17- // 예: "order_updates"라는 토픽 사용
18- kafkaTemplate .send ("order_updates" , message );
19+ try {
20+ // Kafka로 주문 업데이트 이벤트 전송
21+ kafkaTemplate .send ("order_updates" , message );
22+ log .info ("주문 이벤트 전송 성공: {}" , message );
23+ } catch (Exception e ) {
24+ // Kafka 연결 실패 시에도 주문 처리는 계속 진행
25+ log .warn ("Kafka 연결 실패로 주문 이벤트 전송 실패, 주문 처리는 계속 진행: {}" , e .getMessage ());
26+ log .debug ("Kafka 에러 상세: " , e );
27+ }
1928 }
2029}
You can’t perform that action at this time.
0 commit comments