按照flink官网,直接部署完,启动 sql客户端,已经可以通过sql完成cdc功能。
那单独提供的flink-cdc包又有什么用呢? 为什么要用这个包区完成cdc功能,哪些场景必须用flink-cdc的包。
比如当前最新的flink2.0.0 ,flink-cdc是3.0.4
相似问题