YYChildren opened a new issue, #9414: URL: https://github.com/apache/seatunnel/issues/9414
## 需求描述 1. Seatunel 使用kafka source，格式为 canal_json。每一条消息都带有对应的database 、table 和 sqlType，sqlType 记录了所有的列定义，所以其实 canal_json 自身就已经有完整的 schema 定义。 2. 我的某个topic里会有不同的表，每个表的字段定义都不一样，用一个schema 定义我这个topic 的所有表，显然不合适。 3. 如果我想达到我的目的，应该怎样实现？ ## 参考文档 1. [Schema 特性简介 ](https://seatunnel.apache.org/zh-CN/docs/2.3.11/connector-v2/formats/canal-json) 2. [Canal 格式](https://seatunnel.apache.org/zh-CN/docs/2.3.11/connector-v2/formats/canal-json) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
