在Flink CDC中,如果你使用的是Flink SQL来定义和执行CDC任务,那么通常需要使用包含SQL支持的“胖包”(fat jar),即flink-sql-connector-mysql-cdc
。这是因为这个胖包包含了运行Flink SQL所需的全部依赖项,包括连接器、序列化器等。
相反,如果只使用了瘦包flink-connector-mysql-cdc
,你可能会遇到缺少某些依赖的问题,因为在实际运行时还需要其他的库才能完成完整的功能。
因此,当你在代码中集成Flink CDC时,特别是当使用Flink SQL时,建议使用flink-sql-connector-mysql-cdc
这个胖包以确保所有必需的组件都已包含在内。这样可以避免因为缺少依赖而导致的任务失败或错误。