Flink CDC这种写法咋个能使用到includeSchemaChanges呢？

Flink CDC中的includeSchemaChanges是一个布尔值，用于控制是否包含模式更改的事件。默认情况下，includeSchemaChanges是false，即不包含模式更改的事件。

如果你想使用includeSchemaChanges，你可以在创建CDC Source的时候设置这个属性。例如，如果你使用的是SqlServerSourceBuilder，你可以这样设置：

SqlServerSourceBuilder<Row> builder = SqlServerSourceBuilder.forRecordStreamFormat(...);
builder.withProperty("includeSchemaChanges", true);

这样，你就可以接收到模式更改的事件了。

includeSchemaChanges只能控制是否接收模式更改的事件，不能控制其他类型的事件。例如，如果你只想接收INSERT和UPDATE事件，而不接收DELETE和TRUNCATE事件，你需要在WatermarkStrategy中设置。