Flink CDC 里能抽取达梦数据库嘛？

可以抽取达梦数据库，但需要使用Flink CDC的达梦数据库连接器。

Flink CDC 可以抽取达梦数据库的数据，以下是详细的步骤和配置：

安装 Flink CDC

1、下载 Flink CDC 插件

访问 Flink CDC GitHub 仓库（https://github.com/ververica/flinkcdcconnectors），找到达梦数据库的 CDC 连接器，点击 "Releases" 标签，下载对应版本的二进制文件。

2、将下载的文件放到 Flink 的 lib 目录下。

配置 Flink CDC

1、在 Flink 的配置文件（如 flinkconf.yaml）中，添加以下配置：

cdc.source.dm:
  type: com.ververica.cdc.connectors.dm.DmSourceConnector
  connectionurl: jdbc:dm://localhost:5236/your_database
  user: your_username
  password: your_password

connectionurl 是达梦数据库的连接地址，user 和 password 分别是数据库的用户名和密码。

2、在 Flink SQL 中，创建表并指定数据源为达梦数据库的 CDC：

CREATE TABLE your_table (
  id INT,
  name STRING,
  age INT,
  PRIMARY KEY (id) NOT ENFORCED
) WITH (
  'connector' = 'cdc.source.dm',
  'topic' = 'your_topic'
);

your_table 是你要创建的表名，your_topic 是达梦数据库中对应的 CDC 主题。

启动 Flink CDC

1、编写 Flink SQL 查询语句，从达梦数据库的 CDC 表中读取数据：

SELECT * FROM your_table;

2、执行查询语句，查看结果。

通过以上步骤，Flink CDC 就可以抽取达梦数据库的数据了。