首页 笔记 图片 查字 
所属分类:Flink
浏览:40
内容:

参考:
https://blog.csdn.net/weixin_42845827/article/details/132854512

序列化器的作用是将flink数据转换成 kafka 的 ProducerRecord。
3.1 使用预定义的序列化器
功能:将 DataStream 数据转换为 Kafka 消息中的value,key为默认值null,timestamp为默认值。
3.2 使用自定义的序列化器
功能:可以对 kafka消息的key、value、partition、timestamp进行赋值。