当前位置:首页 > 编程笔记 > 正文
已解决

【Flink】FlinkCDC自定义反序列化器

来自网友在路上 155855提问 提问时间:2023-09-21 07:25:00阅读次数: 55

最佳答案 问答题库558位专家为你答疑解惑

在我们用FlinkCDC采集mysql数据(或其他数据源)的时候,FlinkCDC输出的格式不标准,不利于我们后续做数据处理,我们通常会使用自定义反序列化器来格式化采集数据方便后续处理

常规的反序列化器如下:

public class FlinkDataStreamCDC {public static void main(String[] args) throws Exception {//1.获取Flink 执行环境StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();env.setParallelism(1);//2.通过FlinkCDC构建SourceFunctionDebeziumSourceFunction<String> sourceFunction = MySqlSource.<String>builder().hostname("192.168.0.0").port(3306).username("username").password("password").databaseList("cdc") .deserializer(new StringDebeziumDeserializationSchema()).startupOptions(StartupOptions.initial()).build();DataStre
查看全文

99%的人还看了

猜你感兴趣

版权申明

本文"【Flink】FlinkCDC自定义反序列化器":http://eshow365.cn/6-10540-0.html 内容来自互联网,请自行判断内容的正确性。如有侵权请联系我们,立即删除!