apache-flinkHow to define a custom (de)serialization schema


Introduction

Schemas are used by some connectors (Kafka, RabbitMQ) to turn messages into Java objects and vice-versa.