Flink CDC中column default value的转换能关闭吗？

Flink CDC中column default value的转换是指当从数据库中读取变更数据时，如果某个字段的值为NULL，那么Flink CDC会尝试使用该字段在数据库中定义的默认值来替换NULL。这样做的目的是为了保持数据的一致性和完整性，避免出现空值导致的问题。

如果想关闭这个功能，可以在创建Flink CDC表的时候，使用'column.default-value.enabled'参数来设置是否启用默认值转换。 该参数的默认值为true，表示启用默认值转换。如果想关闭默认值转换，可以将该参数设置为false。

例如，如果想从MySQL读取变更数据，并且关闭默认值转换，您可以这样创建表：

CREATE TABLE mysql_binlog (
  id INT NOT NULL,
  name STRING,
  description STRING,
  weight DECIMAL(10, 3)
) WITH (
  'connector' = 'mysql-cdc',
  'hostname' = 'localhost',
  'port' = '3306',
  'username' = 'flinkuser',
  'password' = 'flinkpw',
  'database-name' = 'inventory',
  'table-name' = 'products',
  'column.default-value.enabled' = 'false' -- 关闭默认值转换
);