[실습] Kafka 객체를 JSON 문자열로 직렬화 구현

writeValueAsString는 JSON 문자열로 데이터를 직렬화하는 매우 편리한 메서드입니다. Kafka 메시지, REST API 응답 데이터, 로그 데이터 등 JSON 형식이 필요한 모든 곳에서 사용할 수 있습니다.

 

 

1. @RestController 생성

    MyController에서 앞으로 url 호출 예정 (post: /message/c 호출)

 

2. Producer 설정

 

3.Consumer

 

<단일 메세지 리스너>

<배치 메세지 리스너>

 

4.config

컨슈머에서 한번에 받기 위해서는 consumer 셋팅에 배치 리스너 설정 값을 변경 해줘야 한다.

factory.setBatchListener(true);

 

 

5. 결과