Outbox Pattern아웃박스 패턴

문제: DB 업데이트 성공 + 메시지 발행 실패 = 불일치

// 잘못된 코드
await db.updateOrder(order);      // DB 성공
await kafka.publish(orderEvent);  // 실패하면?
// → 주문은 처리됐는데 이벤트 없음

-- 아웃박스 테이블
CREATE TABLE outbox (
  id          UUID PRIMARY KEY,
  topic       VARCHAR(255),
  payload     JSONB,
  created_at  TIMESTAMP,
  published   BOOLEAN DEFAULT FALSE
);

-- 비즈니스 로직과 같은 트랜잭션에서 삽입
BEGIN;
  UPDATE orders SET status = 'PAID' WHERE id = :orderId;
  INSERT INTO outbox (id, topic, payload)
    VALUES (gen_random_uuid(), 'order.paid',
            '{"orderId": 123, "amount": 5000}');
COMMIT;
-- 둘 다 성공하거나 둘 다 실패 (원자성 보장)

┌─────────────┐    트랜잭션    ┌────────────┐
│ 비즈니스 로직│ ─────────────▶│  DB (주문) │
└─────────────┘               │  DB (아웃박스)│
                               └──────┬─────┘
                                      │ 폴링/CDC
                               ┌──────▼─────┐
                               │ 릴레이 서비스│
                               └──────┬─────┘
                                      │
                               ┌──────▼─────┐
                               │  Kafka/MQ  │
                               └────────────┘

Debezium CDC 활용:
  MySQL binlog / PostgreSQL WAL 감지 →
  outbox 테이블 변경 → 자동 Kafka 발행

@Service
@Transactional
public class OrderService {
    public void processOrder(Order order) {
        // 1. 비즈니스 로직
        orderRepository.save(order);

        // 2. 아웃박스에 이벤트 삽입 (같은 트랜잭션)
        OutboxEvent event = OutboxEvent.builder()
            .topic("order.paid")
            .payload(toJson(new OrderPaidEvent(order.getId())))
            .build();
        outboxRepository.save(event);
        // 트랜잭션 커밋 시 둘 다 성공 또는 실패
    }
}

// 릴레이 스케줄러
@Scheduled(fixedDelay = 1000)
public void relayOutboxEvents() {
    List<OutboxEvent> events = outboxRepository
        .findByPublishedFalse();
    for (OutboxEvent event : events) {
        kafkaTemplate.send(event.getTopic(), event.getPayload());
        event.setPublished(true);
    }
}