목록 보기
Kafka Message Conversion (Serial/Deserializing)
백엔드

Kafka Message Conversion (Serial/Deserializing)

여기어때
여기어때
2025년 2월 24일

두줄요약

Kafka 소비 시 JSON 역직렬화 설정이 왜 기대대로 동작하지 않는지 과정을 따라가며 분석했습니다. 헤더 타입 정보와 타입 매핑, trusted packages, target type 우선순위를 조정해 해결했습니다.

핵심 내용

  • Kafka 메시지 소비 시 StringDeserializer 후 ObjectMapper 변환과 JsonDeserializer 직변환 방식의 차이를 탐색한 과정
  • trusted packages 오류와 클래스 경로 불일치 문제를 TYPE_MAPPINGS, TRUSTED_PACKAGES, useHeadersIfPresent 설정으로 해결한 시도
  • JsonDeserializer 내부의 타입 추론 흐름과 헤더 기반 타입 우선순위 동작을 소스 코드로 분석
  • 최종적으로 헤더 타입 정보를 무시하고 target type을 사용하도록 설정한 뒤 정상 변환되는 원리 설명

다음 읽기

#Kafka 주제를 이어서 읽기

공통 Kafka 전환기 [Part 2. 공통 Kafka 전환 여정]

도메인별로 분산 운영되던 8개 Kafka 클러스터를 공통 Kafka로 통합하는 전환 과정을 정리했습니다. MirrorMaker2 기반 점진 전환으로 서비스 영향 없이 데이터 일관성과 Offset을 유지했습니다.

여기어때
여기어때
백엔드

댓글 0개

댓글을 작성하려면 로그인이 필요합니다.

댓글을 불러오는 중...