flink-connector-mysql-cdc

flink-connector-mysql-cdc是一个用于连接Flink和MySQL Change Data Capture（CDC）的jar包。您可以通过访问https://mvnrepository.com/artifact/com.alibaba.ververica/flink-connector-mysql-cdc/下载这个jar包，并将其复制到Flink安装位置的lib目录中。

在使用flink-connector-mysql-cdc之前，您需要启动Flink SQL Client，并执行以下SQL语句：

CREATE TABLE mysql_binlog (
  id INT NOT NULL,
  name STRING,
  age INT
) WITH (
  'connector' = 'mysql-cdc',
  'hostname' = 'localhost',
  'port' = '3306',
  'username' = 'root',
  'password' = '123456',
  'database-name' = 'demo',
  'table-name' = 'student'
);

CREATE TABLE sink_table (
  id INT NOT NULL,
  name STRING,
  age INT
) WITH (
  'connector' = 'print'
);

INSERT INTO sink_table SELECT id, name, age FROM mysql_binlog;

这些SQL语句会创建名为mysql_binlog的表，并将其与MySQL的binlog进行连接。同时，它还会创建名为sink_table的目标表，用于接收来自mysql_binlog表的数据，并使用print连接器将数据打印出来。

如果您需要更详细地了解Flink CDC的配置，您可以参考一篇名为《Flink CDC》的文章。在该文章中，您可以深入了解CDC的配置和MySQL如何启用binlog功能。