怎么在 flink 计算上使用 这样的 cdc？

要在实时计算Flink中使用社区版本的CDC连接器，请遵循以下步骤：1. 选择合适的社区release版本：• 访问CDCConnectorsforApacheFlink社区文档，在页面左下角选择与您的实时计算Flink(VVR)版本相对应的社区版本。例如，对于VVR的不同版本，有如下对应关系： • release-1.4：选择1.13-4.0.0至1.13-4.0.6版本• release-2.0：选择1.13-4.0.7至1.13-4.0.9版本• 以此类推，确保选择的社区版本与VVR版本兼容。• 下载连接器：• 在选定的社区文档页面中，进入相应CDC连接器的子页面，点击.jar链接下载该连接器的发布版本。或者，您可以通过访问Maven中央仓库，https://search.maven.org/ 搜索com.ververica󠁪来下载对应的jar包。• 上传连接器到实时计算控制台：• 登录实时计算控制台，进入目标工作空间的操作列，点击“控制台”，然后在左侧导航栏选择“数据连接”。• 点击“创建自定义连接器”，上传第二步中下载的jar文件，并完成上传过程。• 在SQL作业中使用连接器：• 编写SQL作业时，通过connector󠁪参数指定您上传的连接器名称。具体支持的参数请参考社区文档中对应连接器的说明。• 对于Jar作业：• 在项目的pom.xml󠁪文件中添加对应的依赖，确保指定正确的groupId、artifactId和version。需要注意的是，Maven仓库通常只包含release版本，如果需要快照版本，需要从GitHub克隆仓库并自行编译。• 在代码中导入对应的连接器实现类，并根据文档指导进行使用。请注意，如果您使用的连接器名称与内置连接器冲突，需要按照文档指南更改连接器名称以避免冲突。 此回答整理自钉群“实时计算Flink产品外部客户交流群”