kafka
KafkaListener에서 서로 다른 message mapping하기
다른 2개의 서비스에서 동일 토픽을 다른 클래스(서비스내 클래스)로 매핑하는 방법이다. [A서비스에서 메시지 발행] topicId: message-topic message는 2가지 발행: service1.model.TextMessage, service1.model.FileMessage [B서비스에서 메시지 구독] topicId: message-topic message는 2가지 발행: service2.model.TextMessage, service2.model.FileMessage spring kafka에서 발행한 메시지의 헤더를 보면 __TypeID__라는 것이 있다. 이것은 메시지를 보낼 때의 데이터 객체 타입을 매핑하여 전송하게 되고 실제 수신받는 컨슈머는 이 객체타입을 사용하여 deserialize..
2022. 12. 23. 07:36