공유 브로커에서 라우팅 키로 Kafka 소비자 테스트를 분리하는 방법

공유 브로커에서는 라우팅이 토픽에서 끝나기 때문에 Kafka consumer 변경을 검증하기가 어렵고, 테스트 트래픽을 분리하기도 힘듭니다.

해결책으로 요청 컨텍스트에 담긴 불투명한 routing key를 producer가 메시지 헤더에 넣고, consumer가 이를 확인하도록 합니다.

이 방식이면 전체 Kafka 스택을 복제하지 않고도 공유 브로커 위의 ephemeral 환경에서 현실적인 end-to-end 테스트를 돌릴 수 있습니다.

OpenTelemetry baggage와 consumer 측 필터링을 활용해 비동기 흐름을 안전하게 격리하고 검증할 수 있습니다.