Flink CDC中ddl语句变更 有通知吗 我看mysqlcdc官方文档没看到呢？

在Flink CDC中，DDL语句的变更通知机制主要依赖于具体的实现方式和配置。以下是关于Flink CDC中DDL语句变更的相关说明：

1. DDL事件的捕获

Flink CDC可以通过配置来捕获MySQL中的DDL事件。如果您使用的是社区版本的CDC连接器，可以通过MySqlSource API并设置includeSchemaChanges(true)参数来获取DDL事件。例如：

MySqlSource<xxx> mySqlSource =
 MySqlSource.<xxx>builder()
 .hostname(...)
 .port(...)
 .databaseList("<databaseName>")
 .tableList("<databaseName>.<tableName>")
 .username(...)
 .password(...)
 .serverId(...)
 .deserializer(...)
 .includeSchemaChanges(true) // 配置获取DDL事件的参数
 .build();

通过上述配置，您可以捕获到MySQL中的DDL事件，并在代码中编写逻辑对这些事件进行处理。

2. DDL变更的同步策略

对于DDL变更的同步，Flink CDC支持通过CTAS（CREATE TABLE AS）或CDAS（CREATE DATABASE AS）语法实现整库同步。然而，需要注意以下几点： - 不支持的DDL变更类型：包括主键或索引等约束的变更、非空列的删除、从NOT NULL转为NULLABLE的变更等。如果遇到这些不支持的DDL变更，您需要手动删除下游结果表并重新启动CTAS作业。 - 宽容模式：对于不支持列类型变更的下游系统（如Hologres），可以使用宽容模式同步数据。宽容模式应在首次启动CTAS作业时开启，否则需要删除下游表并重启作业才能生效。

3. DDL变更的通知机制

Flink CDC本身不会主动通知DDL变更，而是通过捕获Binlog中的DDL事件来感知变更。因此，是否能够接收到DDL变更通知，取决于以下因素： - MySQL Binlog配置：确保MySQL的Binlog未忽略相关数据库或表的变更。您可以通过SHOW MASTER STATUS命令检查Binlog_Do_DB和Binlog_Ignore_DB的配置。 - Flink CDC配置：确保在Flink CDC中启用了includeSchemaChanges(true)参数以捕获DDL事件。

4. 官方文档的说明

根据知识库中的信息，原DDL内容已移至连接器目录下，建议查看支持的连接器文档以获取最新的DDL相关说明。如果您在MySQL CDC官方文档中未找到相关信息，可能是因为文档优化调整后相关内容被迁移。

5. 重要提醒

• 手动处理DDL变更：对于不支持的DDL变更类型，您需要手动干预，包括删除下游表并重新同步历史数据。
• Binlog过滤器的影响：如果某个库的表无法同步增量数据，而其他库可以，可能是由于MySQL服务器配置了Binlog过滤器，忽略了某些库的Binlog。

综上所述，Flink CDC中DDL语句的变更是通过捕获Binlog中的DDL事件来实现的，但需要正确配置MySQL和Flink CDC的相关参数。如果您未在官方文档中找到相关信息，建议参考支持的连接器文档或联系技术支持以获取进一步帮助。