【Flink】 FlinkCDC读取Mysql（ DataStream 方式）（带完整源码，直接可使用）-Toy模板网

这篇具有很好参考价值的文章主要介绍了【Flink】 FlinkCDC读取Mysql（ DataStream 方式）（带完整源码，直接可使用）。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

简介：

FlinkCDC读取Mysql数据源，程序中使用了自定义反序列化器，完整的Flink结构，开箱即用。

本工程提供

1、项目源码及详细注释，简单修改即可用在实际生产代码

2、成功编译截图

3、自己编译过程中可能出现的问题

4、mysql建表语句及测试数据

5、修复FlinkCDC读取Mysql数据时间戳差8小时问题

6、自定义反序列化器让FlinkCDC读取和后续的处理更方便

一、成功编译成功信息如下

【Flink】 FlinkCDC读取Mysql（ DataStream 方式）（带完整源码，直接可使用）,Flink解决方案,flink,大数据

二、自己编译过程中可能出现的问题

FLINK:ClassNotFoundException: org.apache.flink.streaming.api.functions.source.SourceFunction_一杯咖啡半杯糖的博客-CSDN博客

三、mysql建表语句及测试数据，Mysql版本5.7

CREATE TABLE `cdc_test` (
`id` int(11) NOT NULL,
`name` varchar(12) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT NULL,
`create_time` datetime DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4

INSERT INTO cdc.cdc_test (id,name,create_time) VALUES
   (1,'li',NULL),
   (2,'zhang','2023-09-13 09:27:18'),
   (3,'liu','2023-09-13 09:30:18'),
   (4,'wu1','2023-09-13 10:30:18'),
   (5,'aa','2023-09-13 09:30:18');