WEBBOOK CHAPTER

Kafka 이벤트 스트리밍, 개발에서 운영까지: 3장. Topic을 수명주기 단위로 설계한다

3장. Topic을 수명주기 단위로 설계한다

topic은 팀·업무 사건·보존·보안·처리량이 비슷한 record를 묶는다. 이벤트마다 topic 하나나 모든 이벤트 topic 하나를 피한다. owner, partition, replication, retention, cleanup, ACL과 종료 절차를 catalog에 둔다.

손쉽게 따라 하기

예약 사건 topic의 생성·변경·폐기 checklist를 작성한다. 입력에는 실제 고객·계정·도메인 대신 tenant-demo, example.invalid와 저장소 fixture만 사용한다. 시작 전 기대 결과와 바꾸지 않을 불변식을 한 줄로 적는다.

같은 화면에서 확인할 증거

lab/public/index.html의 공통 FieldPass Evidence Board에서 책 slug kafka-event-streaming-operations, 장 번호 3, run ID를 선택한다. 입력, 판정, 관측값, rollback을 채우고 명령 결과와 같은지 확인한다. 성공 화면만 캡처하지 않고 의도한 실패 하나와 다음 안전 행동을 함께 남긴다.

막혔을 때

고아 topic은 traffic·consumer·owner 확인 뒤 quarantine한다. 원인을 확정하기 전 최근 변경, 환경, 권한, 시간 범위와 실제 오류를 고정한다. 외부 서비스를 반복 호출하지 않고 로컬 fixture로 최소 재현한 뒤 한 변수만 바꾼다. 복구는 process 상태가 아니라 FieldPass 예약·결제·정산의 업무 결과로 선언한다.