Flink Kafka 连接器 - KafkaSerializationSchema 接口详解

org.apache.flink.streaming.connectors.kafka.KafkaSerializationSchema 是 Flink Kafka 连接器中用于将数据序列化为 Kafka 消息的接口。它定义了一个方法 serialize(T element, @Nullable Long timestamp) 来将数据元素转换为 Kafka 消息。该接口还可以定义配置 Kafka 生产者的属性，例如 Kafka 主题，分区等。