shiyuyang created FLINK-34903:
---------------------------------
Summary: Add mysql-pipeline-connector with table.exclude.list
option to exclude unnecessary tables
Key: FLINK-34903
URL: https://issues.apache.org/jira/browse/FLINK-34903
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Reporter: shiyuyang
Fix For: cdc-3.1.0
When using the MySQL Pipeline connector for whole-database synchronization,
users currently cannot exclude unnecessary tables. Taking reference from
Debezium's parameters, specifically the {*}table.exclude.list{*}, if the
*table.include.list* is declared, then the *table.exclude.list* parameter will
not take effect. However, the tables specified in the tables parameter of the
MySQL Pipeline connector are effectively added to the *table.include.list* in
Debezium's context.
In summary, it is necessary to introduce an externally-exposed
*table.exclude.list* parameter within the MySQL Pipeline connector to
facilitate the exclusion of tables. This is because the current setup does not
allow for excluding unnecessary tables when including others through the tables
parameter.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
