赞
踩
简介:
FlinkCDC读取Mysql数据源,程序中使用了自定义反序列化器,完整的Flink结构,开箱即用。
本工程提供
1、项目源码及详细注释,简单修改即可用在实际生产代码
2、成功编译截图
3、自己编译过程中可能出现的问题
4、mysql建表语句及测试数据
5、修复FlinkCDC读取Mysql数据时间戳差8小时问题
6、自定义反序列化器让FlinkCDC读取和后续的处理更方便
CREATE TABLE `cdc_test` (
`id` int(11) NOT NULL,
`name` varchar(12) CHARACTER SET utf8mb4 COLLATE utf8mb4_
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。