서비스끼리 직접 부르지 않고, 메시지로 대화하게 하려면?

주문 서비스가 결제·재고·알림 서비스를 동기 REST로 직접 부른다고 해봐요. 겉보기엔 단순하지만, 세 가지가 발목을 잡습니다.

비동기 메시징은 이 사이에 브로커(broker)를 끼워 넣어요. 생산자는 브로커에 메시지를 던지고 바로 리턴하고, 소비자는 자기 속도로 꺼내 처리합니다.

@KafkaListener(topics = "payments")
public void handle(PaymentEvent e) {
    // at-least-once: 같은 이벤트가 두 번 올 수 있다
    if (processedRepo.existsById(e.getEventId())) {
        return;                 // 이미 처리 → 조용히 무시 (멱등)
    }
    applyPayment(e);            // 실제 처리
    processedRepo.save(new Processed(e.getEventId()));
}

서비스가 자기 DB를 갱신하면서 메시지도 발행해야 하는 일은 매우 흔해요. 문제는 이 둘이 서로 다른 시스템이라 하나의 트랜잭션으로 묶기 어렵다는 겁니다.

Spring for Apache Kafka는 @KafkaListener로 소비자를 선언적으로 만들어요. 메서드가 정상 리턴하면 오프셋이 커밋되고, 예외가 나면 재처리 흐름을 탑니다.

@KafkaListener(topics = "orders", groupId = "order-svc")
public void onOrder(OrderEvent e) {
    orderService.process(e);   // 예외 던지면 에러 핸들러가 재시도/DLQ 결정
}