多张oracle表变更同步到同一个kafka topic,现在实时flinlk作业需要消费其中一张oracle表,查了一下没看到类似canal json格式中 

canal-json.database.include 和 canal-json.table.include 参数,只在available 
metadata中看到 table 字段,这意味着我需要在select语句中按table字段进行过滤吗?


[1] 
https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/connectors/table/formats/ogg/
[2] 
https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/connectors/table/formats/canal/

回复