[TIL] 프로젝트 11일차.. 드디어 재고 감소랑 배송 생성이랑 연결을?!

🌞 오늘은 어떤 하루였지..

오늘은 드디어 재고 감소 로직이랑 배송 생성 로직을 Kafka를 활용해서 연결하려고 했다!

근데 막상 연결하려고 설계를 하다 보니 문제가 발생했다..
배송을 생성할 때 필요한 데이터들을 전부 받아올 수 없는 것이었다..

배송을 생성하기 위해서는 orderId, sellerId, senderId, addressId, deliveryRequest 가 필요하다.
하지만 지금 당장 받아올 수 있는 것은 orderId와 sellerId이고 나머지는 받아올 수 없는 것이었다..

그래서 프로젝트를 같이 진행하는 팀원들과 얘기해본 결과 Sender(출고지(물류센터))와 Seller(판매자) 사이에는 연관관계를 추가하여 판매자가 어느 출고지(물류센터)로 상품을 보내서 관리해야 하는지 확인해야 했다.

또 쿠팡을 살펴보니 주문 페이지에서 배송지를 함께 표시해주고 있어서 주문과 주소 사이에도 연관관계가 필요하다는 것을 깨달았다. 그리고 배송 요청사항은 각 회원마다 배송지를 저장할 때 함께 저장하고 있는 시스템이었다.

이 내용들을 종합해서 회고 시간에 각각 담당하는 팀원들에게 내용들 설명해 주고 합의점을 찾게 되었다.
이미 주문을 생성할 때 모든 정보를 받아서 넘기기 때문에 주문 파트에서는 문제가 없었고, 주소에 배송 요청사항을 추가하는 것과 출고지(물류센터)와 판매자 사이에 연관관계를 추가하는 것. 이 두 가지만 해결한다면 재고 감소 로직과 배송 생성 로직을 연결할 수 있을 것 같다.

그리고 오늘부터 약 일주일정도 내가 프로젝트를 리딩하게 되었는데, 갑자기 찾아온 상황이라 당황스럽기도 하지만 이 상황을 잘 해결해 나간다면 나에게 또 성장할 수 있는 시간이 될 것이라고 생각한다.
프로젝트를 리딩하는 동안 더 열심히 해서 잘 진행될 수 있도록 이끌어야겠다!

 

💡 새롭게 알게 된 내용은 뭐가 있더라..?!

Kafka Consumer에서 다른 Producer 호출하기

Kafka 기반 아키텍처를 구성하면서, 하나의 Consumer가 메시지를 처리한 후 또 다른 Producer를 호출해 다음 단계의 메시지를 전송하는 구조를 처음으로 적용해봤다.

• 구조 → Kafka Consumer 내부에서 비즈니스 로직 수행 후, 다른 Kafka Producer를 호출
• 목적 → 메시지를 통한 단계적 흐름 처리 (ex. 재고 감소 → 배송 생성)
• 장점 → 시스템 간 결합도 없이 이벤트 흐름을 이어갈 수 있다.

🧩 실제 적용한 구조

[TestController] → ProductProducer → Kafka (stock-topic)
                     ↓
               ProductConsumer (재고 차감)
                     ↓
          🆕 DeliveryProducer (배송 메시지 전송)
                     ↓
             DeliveryConsumer → 배송 생성

🧪 적용 포인트

Consumer에서 다른 Producer를 주입받아 호출이 가능하다.

@RequiredArgsConstructor
@Component
public class ProductConsumer {
    private final DeliveryProducer deliveryProducer;

    @KafkaListener(topics = "stock-topic", ...)
    public void listen(...) {
        ...
        deliveryProducer.sendCreateDeliveryMessage(...);
    }
}

다음 단계로 이벤트를 넘기는 방식으로 프로세스 흐름의 유연성을 확보할 수 있다.
동기 호출이 아닌 비동기 이벤트 처리 방식이라 확장성에 유리하다.

⚠️ 유의사항

• 예외 처리 → 메시지 처리 중 예외가 발생할 경우, 재처리 정책 또는 DLQ 필요 여부 검토가 필요하다.
• 메시지 유효성 → 전달할 DTO는 직렬화 가능한 형태로 설계해야 한다.
• 순서 보장 → Kafka 파티션 키 설정이 없으면 메시지 순서 보장은 불가할 수 있다.

🔍 오늘의 인사이트

Kafka 메시지 기반 처리에서 이벤트 간 흐름을 이어주기 위해 Consumer → 다른 Producer 호출 구조가 유용하다는 걸 처음 체감했다.
이 구조는 향후 다양한 비즈니스 시나리오에서 적용할 수 있는 중요한 메시지 패턴이라는 것을 깨달았다.

 

🗓️ 내일은 뭐 하지?!

✔️ 재고 감소 로직과 배송 생성 로직 연결 마무리하기
✔️ API 명세서 수정
✔️ TIL 작성