Kafka 영속 경로

최신 안정판 Javers 0.2.1 릴리스 기준

KafkaCdoSnapshotRepository는 쓰기 전용 JaVers 어댑터입니다. 인코딩한 CdoSnapshot을 Kafka로 발행하지만 관계형 스냅샷 저장소가 아니며 JaVers 이력 조회에도 쓸 수 없습니다.

// kafkaTemplate에 "javers-snapshots"를 default topic으로 먼저 설정합니다.
val repository = KafkaCdoSnapshotRepository(kafkaTemplate)
val javers = JaversBuilder.javers()
    .registerJaversRepository(repository)
    .build()

saveSnapshot은 일반 JSON으로 인코딩한 뒤 GlobalId를 레코드 키로 삼아 sendDefault를 호출합니다. 전송 결과는 최대 30초 동안 기다립니다. 전송 실패, 시간 초과, 스레드 중단은 실행 오류로 전달하며, 중단 상태도 복원합니다. getKeys, contains, getSeq, getSnapshotSize, loadSnapshots는 경고를 남기고 빈 값이나 0을 돌려줍니다. 어댑터를 새로 만들면 마지막 스냅샷의 위치도 복원하지 못합니다. 정확한 계약은 KafkaCdoSnapshotRepository.kt와 KafkaCdoSnapshotRepositoryTest.kt에 있습니다.

Kafka의 순서는 파티션 안에서만 보장됩니다. 같은 GlobalId 키는 보통 같은 파티션으로 가지만, 프로듀서 재시도부터 소비자 처리, 토픽 설정, 프로젝션 저장까지 아우르는 단 한 번 처리 보장은 없습니다. 여러 스냅샷을 발행하다 실패하면 앞부분만 남을 수 있고, 다시 시도하면 중복될 수 있습니다.

Kafka 발행 자체가 저장소의 목적이고 소비자가 스냅샷 스키마를 이해할 때만 이 어댑터를 고르세요. JaVers 조회도 필요하면 Exposed나 Redis를 저장소로 두고 별도 실패 전략 아래 이벤트를 발행해야 합니다. 저장소 조합을 함께 읽으세요.