探索云世界
在使用 Flink CDC 从 MySQL 捕获变更数据并传输到 Kafka 时，我想知道在 Kafka 的建表语句中应该使用哪种连接器类型，是 kafka 连接器还是 upsert-kafka 连接器？此外，在从 Kafka 将数据传输到 Hudi 时，应该使用哪种连接器？
写回答
从MySQL CDC到Kafka建表语句中使用的连接器类型是Flink CDC。
Flink CDC是一个用于捕获和处理数据库变更的Source Connector，它能够监测并捕获MySQL等数据库的变动，包括数据或数据表的插入、更新、删除等操作，并将这些变更记录写入到消息中间件如Kafka中。在创建Flink MySQL CDC表之后，可以将这些变更推送到Kafka主题中，以供其他服务订阅及消费。
再将数据从Kafka传输到Hudi中使用的连接器是内置的Hudi连接器。
Flink全托管内置了Hudi连接器，这样可以降低运维复杂度，并提供SLA保障。使用Flink CDC与Hudi连接器联动，可以实现数据的高效入湖，即从数据库通过CDC捕获变更，再通过Flink写入到Hudi表中，这是一种端到端的解决方案。这种方案不仅降低了开发门槛，还提供了完善的数据连通性，使得数据可以在Flink、Spark、Presto或Hive之间无缝流转。
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
