多张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/