Flink CDC 3.0中，如果你想在同步MySQL数据时排除某列

在Flink CDC 3.0中，如果你想在同步MySQL数据时排除某列，你可以在创建Source表时使用EXCLUDE_ALL选项。以下是一个示例：

CREATE TABLE source_table (
    id INT,
    name STRING,
    age INT
) WITH (
    'connector' = 'mysql-cdc',
    'hostname' = 'localhost',
    'database-name' = 'testdb',
    'table-name' = 'test_table',
    'exclude-columns' = 'age',
    'change-data-capture.column-filtering-mode' = 'EXCLUDE_ALL'
);

在这个示例中，exclude-columns参数用于指定要排除的列，change-data-capture.column-filtering-mode参数用于启用列过滤。这样，在同步数据时，age列将被排除。
在Flink CDC 3.0中，如果你想在同步MySQL数据时排除某列，你可以在创建Source表时使用EXCLUDE_ALL选项。以下是一个示例：

CREATE TABLE source_table (
    id INT,
    name STRING,
    age INT
) WITH (
    'connector' = 'mysql-cdc',
    'hostname' = 'localhost',
    'database-name' = 'testdb',
    'table-name' = 'test_table',
    'exclude-columns' = 'age',
    'change-data-capture.column-filtering-mode' = 'EXCLUDE_ALL'
);

在这个示例中，exclude-columns参数用于指定要排除的列，change-data-capture.column-filtering-mode参数用于启用列过滤。这样，在同步数据时，age列将被排除。