flink 1.16.2可以使用 flink-connector-mysql-cdc 2.4 吗？

flink 1.16.2可以使用flink-connector-mysql-cdc 2.4版本。

但是需要注意几点:

flink 1.16.2发布于2021年1月,flink-connector-mysql-cdc 2.4发布于2022年4月,两个项目版本存在时间差异。

flink 1.16之后,cdc连接器不再整合在flink核心jar包中,需要单独引入。

建议选择版本兼容的连接器,即匹配flink主版本号的连接器。

具体操作:

引入flink-connector-mysql-cdc-2.4.jar连接器依赖。

检查依赖版本冲突。

尽量选择flink 1.16线上的连接器版本。

版本不兼容可以通过降级连接器版本进行测试。

所以总体来说,flink 1.16.2支持flink-connector-mysql-cdc 2.4版本。