Flink CDC里我现在有一个需求,使用cdc同步数据从mysql-mysql,表结构变化也同步监听,现在mysql连接器可以通过调整参数监听到ddl语句,后面的jdbc链接器是否支持这种需求呢?
jdbc connector 应该是用于维表查询或者sink写入,应该不具备监听source的功能哇。这个是两种connector
'connector' = 'mysql-cdc',"
'connector' = 'jdbc',"。自定义个jdbc sink解析ddl语句。此回答来自钉群Flink CDC 社区。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。