Kafka Message Conversion (Serial/Deserializing)

이 글은 여기어때컴퍼니 주문결제개발팀의 애쉬님이 Kafka 메시지 컨버전, 특히 직렬화(Serialization) 및 역직렬화(Deserialization) 과정에서 겪었던 문제와 해결 과정을 공유합니다. 기존 서비스에서는 Kafka 메시지의 Value를 String으로 받아 ObjectMapper를 이용해 파싱하는 방식을 사용했으나, 이 과정에서 비효율성과 잠재적인 문제를 발견했습니다.

11 환경에서의 Kafka 메시지 직렬화 및 역직렬화 설정과 ConsumerRecord를 활용한 메시지 소비 방식을 상세히 설명합니다. 특히, Producer가 JSON 문자열로 모델을 변환하여 보내는 상황을 가정하고, 이를 Consumer에서 효율적으로 처리하기 위한 방법을 탐구합니다.

이를 통해 Kafka 메시지 처리의 안정성과 성능을 향상시키는 방안을 제시합니다. nsumer에서 효율적으로 처리하기 위한 방법을 탐구합니다. 이를 통해 Kafka 메시지 처리의 안정성과 성능을 향상시키는 방안을 제시합니다.