你好 我这边有很多这种场景,把分库分表的binlog 写入到同一个topic 然后用canal-json解析,这边想获取到json里面的table 字段,
然后根据 table名称加主键 写入到下游 合成一张表,写入到下游表,
然后发现 canal-json 是获取不到表名的,然后这边去修改canal-json的format。
添加 createJsonRowType方法的DataTypes.FIELD("table", DataTypes.STRING())
然后在deserialize方法里面把 table字段set到 data里面去。但是发现这种好像是不成功的 ,请问下 有什么具体点的思路提供下吗,
谢谢大佬们
