Flink 的 1.14.4 版jdbc connector
,兼容性不错,用起来也挺稳定的,尤其你在跑老项目时会顺手。对接MySQL
、Oracle
都没啥大问题,响应快,容错也做得还行。
配合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
包版本,别一不小心下错了,浪费时间还踩坑。