Flink 的 1.14.4 版jdbc connector,兼容性不错,用起来也挺稳定的,尤其你在跑老项目时会顺手。对接MySQLOracle都没啥大问题,响应快,容错也做得还行。

配合CDH6.3用效果还蛮稳,部署简单,拿来就能跑。你如果项目里还在用Scala 2.11或者2.12,也不用太担心,兼容性这块官方早就给你兜住了。

想直接下载的可以去看一下Apache Flink 1.14.4 (Scala 2.12)这个版本,还挺全的。

如果你想在CDH上集成,那就推荐你去这儿瞅瞅:CDH6.3.2 集成 Flink1.14.4,配置步骤都写得清楚。

另外,有时候你还得配个MySQL JDBC驱动,比如这个老版本 5.0.6或者这个通用版都能用,看需求选就行。

如果你是要跟Oracle打交道,也可以看看Flink Oracle CDC Connector 2.3.0,适配起来蛮方便的。

小建议,下载完记得核对下jar包版本,别一不小心下错了,浪费时间还踩坑。