JsonDeserializer vs ObjectMapper: Kafka에서 왜 JsonDeserializer를 쓸까?

 

Kafka 개발을 하다 보면, 메시지 역직렬화(deserialization)를 위해 **JsonDeserializer**와 **ObjectMapper**를 두고 고민할 때가 있습니다. 이 두 라이브러리는 모두 JSON 데이터를 객체로 변환하는 데 사용되지만, Kafka 환경에서는 **JsonDeserializer**가 훨씬 더 적합한 경우가 많습니다. 왜 그럴까요?

1. Kafka에 최적화된 설계

**JsonDeserializer**는 처음부터 Kafka와 함께 사용되도록 설계된 라이브러리입니다. Kafka Consumer가 메시지를 읽어올 때 필요한 특성을 이미 갖추고 있죠. configure 메서드를 통해 환경 설정을 쉽게 할 수 있고, deserialize 메서드는 Kafka 메시지의 바이트 배열을 받아 효율적으로 처리합니다.

반면, **ObjectMapper**는 Jackson 라이브러리의 핵심 클래스로, 웹 애플리케이션이나 일반적인 JSON 처리 등 다양한 환경에서 범용적으로 사용됩니다. Kafka와 직접적인 연관이 없기 때문에, Kafka 메시지 처리 로직을 직접 구현해야 하는 번거로움이 있습니다. 예를 들어, Kafka Consumer의 설정 값을 ObjectMapper에 주입하는 등의 추가적인 작업이 필요하죠.

2. 설정의 용이성

Kafka Consumer의 설정 파일(application.yml 또는 application.properties)에서 **JsonDeserializer**를 사용하면 클래스 경로만 지정해 주면 됩니다.

YAML

 

spring:
  kafka:
    consumer:
      value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer

이후 JsonDeserializer는 Kafka 설정에 따라 자동으로 초기화됩니다. 특히, spring-kafka 라이브러리를 사용하면 설정이 더욱 간편해집니다. 별도의 Bean 설정 없이도 메시지 타입 힌트를 통해 알아서 객체로 변환해 줍니다.

@KafkaListener(topics = "my-topic") public void handleMessage(MyObject myObject) { // do something }

만약 **ObjectMapper**를 사용하려면 별도의 KafkaListener 컨테이너 팩토리를 구성하고, ObjectMapper를 직접 주입해 주는 등 복잡한 설정이 필요합니다. 이는 코드의 가독성을 떨어뜨리고 유지보수를 어렵게 만듭니다.

3. 타입 안전성 (Type Safety)

**JsonDeserializer**는 제네릭 타입을 지원하여, 어떤 클래스로 역직렬화할지 명확하게 지정할 수 있습니다. JsonDeserializer<MyObject>와 같이 사용하면, Kafka 메시지의 JSON이 MyObject 타입으로 변환되도록 강제할 수 있습니다. 이는 타입 불일치로 인한 런타임 오류를 사전에 방지하는 데 큰 도움이 됩니다.

**ObjectMapper**도 유사한 기능을 제공하지만, Kafka 컨텍스트에 맞게 직접 구현해야 합니다. 특히, Map이나 List와 같은 복잡한 타입을 처리할 때는 타입 정보가 유실될 위험이 있어 주의해야 합니다.

---

결론: Kafka에서는 JsonDeserializer를 사용하자

정리하자면, **JsonDeserializer**는 Kafka 메시지 역직렬화라는 특정 목적을 위해 설계되었기 때문에 다음과 같은 장점을 제공합니다.

• 설정의 편의성: 별도 구현 없이 Kafka 설정만으로 간편하게 사용 가능
• 성능 최적화: Kafka 환경에서 효율적으로 작동
• 타입 안전성: 제네릭을 통해 타입 안정성 확보

물론 ObjectMapper가 더 유연한 커스터마이징이 필요한 경우에는 유용할 수 있지만, 일반적인 Kafka 애플리케이션에서는 **JsonDeserializer**를 사용하는 것이 더 효율적이고 안전한 개발 방법입니다.