请问mysql cdc如果我只关注表中个别字段的变更，可以过滤么？

是的，在 MySQL CDC 中，您可以通过配置 column.fields.include.list 属性来选择只关注表中个别字段的变更。该属性可以用来过滤 CDC 事件中的字段，只保留感兴趣的字段。

例如，假设您只关注表 my_table 中的 id 和 name 两个字段的变更，可以将 column.fields.include.list 属性设置为 "id,name"。这样，在 CDC 事件中只会保留 id 和 name 两个字段的变更，其他字段的变更将被过滤掉。

以下是一个示例配置：

json
Copy
{
"name": "mysql-cdc",
"connector": {
"type": "mysql-cdc",
"hostname": "localhost",
"port": "3306",
"username": "root",
"password": "root",
"database-name": "my_database",
"table-name": "my_table",
"column.fields.include.list": "id,name"
}
}
在上面的示例配置中，column.fields.include.list 属性被设置为 "id,name"，表示

你可以用datastream api 去区分下before和after之间的数据变更。此回答整理至钉群“Flink CDC 社区”。