大佬们，用flink cdc 接 TiDB是不是不支持 DDL 呀？

Flink CDC支持捕获TiDB的DDL事件。根据Flink CDC的特性，您可以通过配置获取数据库中的DDL事件。具体到TiDB，虽然直接信息未提及TiDB，但Flink CDC通用的配置方式是支持包括MySQL兼容协议在内的多种数据库的DDL变更捕获。您可以按照以下步骤进行配置以捕获DDL事件：

1. 功能支持：

   • Flink CDC确实支持捕获DDL语句，这包括表结构的更改、索引的创建或删除等操作。

2. 配置步骤：

   • 使用Flink的MySqlSource时，确保在构建source时设置参数.includeSchemaChanges(true)来开启对DDL事件的捕获。示例如下：

     MySqlSource<xxx> mySqlSource =
      MySqlSource.<xxx>builder()
          .hostname("<your_host>")
          .port(<your_port>)
          .databaseList("<databaseName>")
          .tableList("<databaseName>.<tableName>")
          .username("<your_username>")
          .password("<your_password>")
          .serverId(<your_server_id>)
          .deserializer(...)
          .includeSchemaChanges(true) // 开启DDL事件捕获的关键配置
          .build();
     

3. 注意事项：

   • 确保您的TiDB版本与Flink CDC兼容，并且已正确配置了Binlog（TiDB作为MySQL的分支，同样使用Binlog记录数据变更）。
   • 如果TiDB集群配置了任何过滤规则，比如忽略特定库的日志记录，请检查这些设置不会阻止DDL日志的生成和传输。

4. 示例说明：

   • 上述代码片段展示了如何在Flink程序中配置MySQL Source以包含DDL变更。通过此配置，Flink作业将能够监听并处理来自TiDB的结构变更事件。

总结来说，Flink CDC是支持捕获TiDB的DDL变更的，只需正确配置即可实现这一需求。