kafka에서 JSON 메시지를 생성하기 위해 사용자 정의 serializer가 필요합니까?

Question

kafka 대기열에 JSON 메시지를 생성하기 위해 사용자 정의 serializer가 필요한지 알고 싶습니다. 나는 생산할 때 객체를 가지고 작업 할 필요가 없다. 하지만 내가받는 메시지는 kafka 큐에 넣을 JSON 형식이 될 것이다. 소비자는 JSON을 필요한 객체로 구문 분석해야합니다.

이제는 모든 JSON 메시지가 간단한 문자열이되기 때문에 대기열에 JSON 형식의 메시지를 생성하기 위해 사용자 지정 serializer가 필요한지 알고 싶습니다.

Answer 1

네, 기본 사용자 정의 사용자 지정 시리얼 라이저를 구현해야한다고 생각합니다. 기본적으로 String serializer 클래스는 Kafka와 함께 제공됩니다. Encoder<T> 클래스를 임 플 레이 한 다음 toBytes(..) 메서드를 재정의해야합니다.

Here is a nice post 비슷한 사용자 지정 serializer를 구현하는 방법에 대해 설명합니다.