littlebear-xbz opened a new issue, #6428:
URL: https://github.com/apache/seatunnel/issues/6428

   ### Search before asking
   
   - [X] I had searched in the 
[feature](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22Feature%22)
 and found no similar feature requirement.
   
   
   ### Description
   
   Currently, Apache Seatunnel CDC supports multi-table synchronization. 
However, when sinking data to Kafka or a file in the debezium_json format, only 
{before, after, op} information is included, without source information. When 
synchronizing multiple tables to Kafka, it is difficult to distinguish which 
table the data belongs to. Is it possible to add source information to the 
debezium_json format?
   
   目前apache seatunnel cdc支持多表同步, 可是当将数据选择debezium_json sink到kafka 
或者file时,只有{before,after , op} 信息,没有source信息, 当同步多个表到kafka后, 难以区分是哪个表的数据, 
是否可以在debezium_json格式中加入source信息
   
   ### Usage Scenario
   
   Multiple table data is synchronized to Kafka through CDC and then processed 
in real-time subsequently. It is possible to distinguish the ownership of data 
for each table in Kafka.
   
   多表数据通过cdc同步到kafka, 再交由后续实时处理, 可以在kakfa中区分数据归属哪个表
   
   ### Related issues
   
   _No response_
   
   ### Are you willing to submit a PR?
   
   - [ ] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [X] I agree to follow this project's [Code of 
Conduct](https://www.apache.org/foundation/policies/conduct)
   


-- 
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]

Reply via email to