01 引言

最近需要对接腾讯的tdsql，准备使用flink的mysql cdc jar，发现该jar包并不支持tdsql（5.x版本），运行时总是一堆的报错。

报错的根本原因是：flink的mysql cdc jar包里面是基于mysql8.x驱动来打包的，而该版本的tdsql仅支持的jdbc驱动为5.x。

因此，需要做的事情就是降级mysql cdc jar包里面的mysql驱动并重新打包，而mysql驱动包是在mysql cdc也依赖的debezium-connector-mysql里面引用的，所以需要修改的是debezium的包。

02 相关资料

相关的 代码 以及 打包好的jar包 都提交到了Gitee，请参考：https://gitee.com/19931024/flink-sql-connector-tdsql-cdc

本文涉及的相关信息如下：

• flink-cdc-connectors源码：https://github.com/ververica/flink-cdc-connectors
• flink-cdc-connectors文档：https://ververica.github.io/flink-cdc-connectors/master/index.html
• debezium源码：https://github.com/debezium/debezium

03 修改内容

flink-connectors引入debezium-connector-mysql后，降级mysql-conector，主要修改的地方在“../debezium-connector-mysql/pom.xml”：

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>5.1.34</version>
    <exclusions>
        <exclusion>
            <groupId>com.google.protobuf</groupId>
            <artifactId>protobuf-java</artifactId>
        </exclusion>
    </exclusions>
</dependency>

同时还需要修改java代码，核心内容具体有如下:

• src/main/java/io/debezium/connector/mysql/antlr/MySqlAntlrDdlParser.java：
• src/main/java/io/debezium/connector/mysql/MySqlConnectorConfig.java:
• src/main/java/io/debezium/connector/mysql/MySqlValueConverters.java:

还有需要修改zeroDateTimeBehavior的值由“CONVERT_TO_NULL”改为“convertToNull”，全局搜索代码修改即可，不是本文的重点，这里省略。

03 文末

附相关maven命令如下：

## 打包命令
mvn clean package  -Dfile.encoding=UTF-8 -Dmaven.test.skip=true  -f pom.xml
## 查询依赖关系
mvn dependency:tree 

---

本文主要是记录基于flink mysql cdc的代码进行二次开发支持tdsql的cdc connector，希望能帮助到大家，谢谢大家的阅读，本文完！