Flink CDC2.0 开启MySQL binlog、准备测试数据、创建用户
数据同步工具:DataX 从MySQL读取数据,保存到HDFS
hive教程:启动hadoop、mysql、metastore,测试是否启动成功
mysql 的 case when then 用法 和null 的判断
本案例是将hive中的数据,导入到 MySQL中。本质:由于 Hive数据库中的数据存储在 HDFS 上,本质上,是将 HDFS 中的文件,导入到MySQL中
Flink CDC2.0 连接MySQL,将表所有数据打印到控制台
canal1.1.5 将MySQL变化数据发送到kafka(单机模式)
Java使用mysql-connector-java-8.X.jar驱动连接MySQL8
Flink CDC2.0 连接MySQL,增删改数据,查看打印数据格式
hive教程:使用mysql存储元数据