kafka 이벤트 발행 실패 시 at-least-once를 보장하는 방법이 궁금합니다.

안녕하세요! 강의 잘 듣고 있습니다.

아래 issue 메서드 관련해서 질문드립니다.

@Transactional
fun issue(couponId: Long, userId: Long): Issuance {
    val policy = couponIssuePolicyReader.get(couponId)

    val now = LocalDateTime.now()
    if (!policy.isBookingOpen(now)) {
        throw NotStartedException()
    }

    val expiresAt = now.plusDays(policy.validityDays.toLong())
    couponIssuer.tryIssue(couponId, userId)
    issuanceRequestProducer.publish(
        IssuanceRequested(
            couponId = couponId,
            userId = userId,
            issuedAt = now,
            expiresAt = expiresAt,
        )
    )

    return Issuance(
        userId = userId,
        couponId = couponId,
        issuedAt = now,
        expiresAt = expiresAt,
    )
}

해당 코드에서 couponIssuer.tryIssue()(Redis)는 성공했는데 바로 다음 issuanceRequestProducer.publish()(Kafka)가 실패하는 경우 재고는 차감됐는데 이벤트는 유실된 불일치 상태가 될 수 있을 것 같습니다.

만약 재고를 DB로 관리한다면 아웃박스 패턴으로 같은 트랜잭션 안에서 이벤트를 아웃박스 테이블에 적재하고 별도 워커가 Kafka에 발행하는 방식으로 원자성을 보장할 수 있을 것 같습니다.

그런데 지금처럼 재고 자체를 Redis로 관리하는 구조에서는 Redis와 Kafka 각각에 대한 이중 쓰기 문제가 생기고 아웃박스 패턴을 그대로 적용하기는 어려워 보입니다.

만약 해당 구조에서 at-least-once를 보장하려면 어떤 전략을 택해야 하는지 궁금합니다!