首页 > 编程学习 > FLINK-CDC之sql方式的应用(mysql篇)

FLINK-CDC之sql方式的应用(mysql篇)

发布时间:2022/1/17 11:54:14

 1、mysql中创建表,注意,mysql要开启binlog,否则报错

CREATE TABLE `cdc_user` (
    `id` BIGINT(11) NOT NULL,
    `name` VARCHAR(50) NULL DEFAULT NULL COLLATE 'utf8mb4_bin',
    `type` VARCHAR(50) NULL DEFAULT NULL COLLATE 'utf8mb4_bin',
    `desc` TEXT NULL DEFAULT NULL COLLATE 'utf8mb4_bin',
    `deleted` INT(11) NULL DEFAULT NULL,
    PRIMARY KEY (`id`) USING BTREE
)
COMMENT='cdc测试user类'
COLLATE='utf8mb4_bin'
ENGINE=InnoDB;

里面的数据

2、创建maven项目,导入依赖

<?xml version&#
Copyright © 2010-2022 ngui.cc 版权所有 |关于我们| 联系方式| 豫B2-20100000