用的连接器：flink-cdc-pipeline-connector-mysql-3.0.1.jar

运行后提示

[root@bogon flink-cdc-3.0.0]# bin/flink-cdc.sh mysql-to-mysql.yaml
Exception in thread "main" java.lang.RuntimeException: Cannot find factory with identifier "mysql" in the classpath.

配置文件如下：

source:
type: mysql
hostname: 192.168.0.3
port: 3306
username: root
password: 123456
tables: cdz.log_operation

sink:
type: mysql
hostname: 192.168.0.3
port: 3306
username: root
password:123456

route:

• source-table: cdz.log_operation
  sink-table: flink_test.log_operation

pipeline:
name: Sync MySQL
parallelism: 1