尊敬的社区,

我目前正在尝试使用较新版本的Apache Flink(2.0和1.20.1),但遇到了不同类型连接器的版本兼容性问题。具体来说:

Flink 2.0版本CDC连接器缺失:

目前找不到适用于Flink 2.0的CDC连接器版本
是否有官方计划发布支持Flink 2.0的CDC连接器版本?

Flink 1.20.1版本通用连接器缺失:

多个常用连接器(如JDBC、MongoDB等)尚未发布对应Flink 1.20.1的版本
这些连接器的最高版本似乎仍然是针对Flink 1.19开发的
使用低版本连接器是否可行?有什么风险和注意事项?

我的当前环境:

正在评估升级至Flink 2.0或1.20.1
需要的连接器:MySQL-CDC、JDBC、MongoDB、Kafka等其他连接器
当前数据流:从关系型数据库提取数据,经过处理后其他异构数据库中
测试环境中已遇到连接异常和兼容性警告

回复