最新DM8 Flink CDC 连接器工具请点击链接下载：DM8 Flink CDC 连接器工具

下面是参考：

构建步骤

1. 环境准备

# 安装JDK11+（Flink 1.17要求）
# 安装Maven 3.8+
mvn -v

2. 创建Maven项目

<!-- pom.xml基础配置 -->
<project>
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.example</groupId>
    <artifactId>flink-cdc-combined</artifactId>
    <version>1.0.0</version>

    <properties>
        <flink.version>1.17.0</flink.version>
        <flink.cdc.version>3.5.0</flink.cdc.version>
    </properties>

    <dependencies>
        <!-- Flink基础依赖 -->
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-java</artifactId>
            <version>${flink.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-streaming-java</artifactId>
            <version>${flink.version}</version>
        </dependency>

        <!-- Flink CDC核心依赖 -->
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-connector-cdc-base</artifactId>
            <version>${flink.cdc.version}</version>
        </dependency>
        
        <!-- 达梦数据库驱动（需手动下载安装到本地仓库） -->
        <dependency>
            <groupId>com.dm</groupId>
            <artifactId>DmJdbcDriver16</artifactId>
            <version>22.1</version>
        </dependency>
    </dependencies>
</project>

3. 配置shade插件（处理依赖冲突）

<build>
    <plugins>
        <plugin>
            <groupId>org.apache.maven.plugins</groupId>
            <artifactId>maven-shade-plugin</artifactId>
            <version>3.2.4</version>
            <executions>
                <execution>
                    <phase>package</phase>
                    <goals><goal>shade</goal></goals>
                    <configuration>
                        <artifactSet>
                            <excludes>
                                <!-- 排除Flink已提供的依赖 -->
                                <exclude>org.apache.flink:*</exclude>
                            </excludes>
                        </artifactSet>
                        <transformers>
                            <transformer implementation="...">
                                <mainClass>com.example.Main</mainClass>
                            </transformer>
                        </transformers>
                    </configuration>
                </execution>
            </executions>
        </plugin>
    </plugins>
</build>

4.执行构建命令

# 安装达梦驱动到本地仓库（需先下载DmJdbcDriver16.jar）
mvn install:install-file -Dfile=DmJdbcDriver16.jar -DgroupId=com.dm -DartifactId=DmJdbcDriver16 -Dversion=22.1 -Dpackaging=jar

# 执行构建
mvn clean package -DskipTests

注意事项

1. 版本兼容性验证：

• 需确认Flink CDC 3.5是否官方支持Flink 1.17
• 建议优先使用Flink官方推荐的版本组合

2. 依赖冲突处理：

• 使用mvn dependency:tree分析依赖树
• 通过标签排除冲突依赖
• 对于关键冲突类可使用Shade插件的relocation功能

3. 达梦数据库适配：

• 需确保DM JDBC驱动版本与数据库版本匹配
• 需在代码中正确配置DM连接参数：

.addSource(FlinkDmCdcSource.<DMEvent>builder()
    .hostname("localhost")
    .port(5236)
    .databaseName("DMDBMS")
    .schemaName("SCHEMA_NAME")
    .tableName("TABLE_NAME")
    .username("user")
    .password("pwd")
    .build())

4. 部署验证：

• 在Flink集群提交时使用–classpath指定依赖
• 建议先进行单表同步测试
• 监控检查点和状态后端表现