在使用 Flink CDC 我想知道在 Kafka 的建表语句中应该使用哪种连接器类型？

从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之间无缝流转。