【Flink】FLINK-CDC之DataStream方式的应用（mysql篇）

本文主要是介绍【Flink】FLINK-CDC之DataStream方式的应用（mysql篇），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

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

这篇关于【Flink】FLINK-CDC之DataStream方式的应用（mysql篇）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---