Kafka Message Parsing with JsonDeserializer

이 게시글에서는 Kafka 메시지를 소비할 때 Json Value를 파싱하는 과정에서 발생한 문제를 다룹니다. 초기 설정은 StringDeserializer를 사용하여 Kafka 메시지를 문자열로 소비하였고, ObjectMapper를 통해 변환하는 방식이었습니다. 그러나 Producer 설정에서 JsonSerializer를 사용하여 메시지를 직렬화한 것을 발견하고, Consumer에서도 JsonDeserializer를 설정해야 할 필요성을 느꼈습니다.

JsonDeserializer 설정 방법

JsonDeserializer를 설정할 때는 TYPE_MAPPINGS와 TRUSTED_PACKAGES를 설정해야 합니다. 이를 통해 Producer와 Consumer 간의 메시지 변환이 가능해집니다. 그러나 이 과정에서 휴먼 에러의 가능성이 증가한다는 피드백을 받았습니다.

타입 추론 방식

JsonDeserializer의 사용시, 'useHeadersIfPresent'를 false로 설정함으로써 타입 추론 방식을 사용할 수 있게 되었고, 이를 통해 메시지 파싱이 성공적으로 이루어졌습니다. 이 과정에서 Kafka의 공식 문서를 참고하여 설정을 최적화할 수 있었습니다.