请问Flink CDC 2.2版本支持源表DDL同步了吗？

Flink CDC 2.2版本支持源表的DDL同步。通过配置includeSchemaChanges(true)参数，您可以使MySqlSource在DataStream API中包含DDL事件的处理。这允许您获取数据库中的DDL变更，例如表结构的修改，从而实现源表的结构同步。

配置示例代码如下：

MySqlSource<xxx> mySqlSource =
    MySqlSource.<xxx>builder()
        .hostname(...)
        .port(...)
        .databaseList("<databaseName>")
        .tableList("<databaseName>.<tableName>")
        .username(...)
        .password(...)
        .serverId(...)
        .deserializer(...)
        .includeSchemaChanges(true) // 配置以包含DDL变更
        .build();

请确保您的Flink版本和相关依赖支持此特性，并根据实际需求调整其他配置项。