flink cdc 不需要目标表也用cdc connector吧？普通的connector可以不?
flink cdc 不需要目标表也用cdc connector吧？普通的connector可以不?
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
-
公众号：网络技术联盟站，InfoQ签约作者，阿里云社区签约作者，华为云 云享专家，BOSS直聘 创作王者，腾讯课堂创作领航员，博客+论坛：https://www.wljslmz.cn，工程师导航：https://www.wljslmz.com
在使用Flink CDC Connector进行数据抽取时，并不需要指定具体的目标表。Flink CDC Connector主要是用于将数据抽取到消息队列、内存表或外部存储系统中，而不是将数据直接写入目标表中。因此，在使用Flink CDC Connector时，不需要事先创建目标表，只需要指定数据抽取的源表，以及数据抽取后的输出位置即可。
当然，如果需要将数据从消息队列或外部存储系统中导入到实际的目标表中，可以使用Flink提供的Table API或DataStream API进行数据处理和写入操作。同时，也可以通过定义Flink SQL的SQL语句，将数据从消息队列或外部存储系统中导入到目标表中（具体语法请参考Flink官方文档）。
在Flink中，使用普通的Connector可能也可以实现数据抽取的功能，但其对于CDC场景特别是无中断数据抽取场景并不特别友好。Flink CDC Connector具有更好的数据可靠性和一致性，可以在数据源变化时自动进行动态调整、重新抽取数据，并保证数据的一致性。因此对于需要实时更新抽取的数据的业务场景，使用Flink CDC Connector更为合适。
2023-04-30 23:04:43赞同 展开评论 -
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
