![](https://img1.daumcdn.net/thumb/R750x0/?scode=mtistory2&fname=https%3A%2F%2Fblog.kakaocdn.net%2Fdn%2FW9vIV%2FbtsHUR1FPeR%2FKy9qTeOkxqu2RRo5VyxqV0%2Fimg.jpg)
개요이번 글의 주제는 Kafka, Pulsar와 같은 Event Streaming 플랫폼, 그리고 이를 소비하는 Flink에서 메세지를 주고받을 때 Serialization, Deserailization을 하는 이유를 알아보는 것입니다. Flink 예제 코드를 보면서 동작 과정을 분석할 때 정확히 알아야 겠다는 생각이 들어서 조사해 보았습니다.PulsarSource source = PulsarSource.builder() .setServiceUrl("pulsar://host.docker.internal:6650") .setTopics("order-topic") // Deserialization - 왜 할까? ..