ruanhang1993 commented on PR #3767: URL: https://github.com/apache/flink-cdc/pull/3767#issuecomment-2750376190
@JNSimba Thanks for your PR. I have some questions about the usage of [column.include.list](https://debezium.io/documentation/reference/1.9/connectors/mysql.html#mysql-property-column-include-list). Consider that there are 3 tables db1.table1, db1.table2 and db1.table3 to read, whose schema are the same. | name | type | note | | ----------- | ----------- | ----------- | | id | varchar | primary key| | name | varchar | | | age | int | | | address | varchar | | For a table source as follows, will the change events contain all columns for `db1.table2` and `db1.table3` in incremental phase? ```sql CREATE TABLE test_tbl ( `id` STRING NOT NULL, name STRING, age INT, address STRING, primary key (`id`) not enforced ) WITH ( 'connector' = 'mysql-cdc', 'database-name' = 'db1', 'table-name' = 'table[0-9]+', 'debezium.column.include.list' = 'db1.table1.id,db1.table1.name', ...... ); ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
