SoulSong commented on issue #8619: URL: https://github.com/apache/seatunnel/issues/8619#issuecomment-2642375696
> Hi [@SoulSong](https://github.com/SoulSong) > > > Expect output message format as change stream realtime origin format. > > Can you explain what's format do you want. SeaTunnel can also support debezium format. Is this what you wanted? https://seatunnel.apache.org/docs/2.3.9/connector-v2/formats/cdc-compatible-debezium-json/ https://seatunnel.apache.org/docs/2.3.9/connector-v2/formats/debezium-json/ The original format: https://seatunnel.apache.org/zh-CN/docs/2.3.9/connector-v2/source/MongoDB-CDC#format-of-real-time-streaming-data ``` { _id : { <BSON Object> }, // Identifier of the open change stream, can be assigned to the 'resumeAfter' parameter for subsequent resumption of this change stream "operationType" : "<operation>", // The type of change operation that occurred, such as: insert, delete, update, etc. "fullDocument" : { <document> }, // The full document data involved in the change operation. This field does not exist in delete operations "ns" : { "db" : "<database>", // The database where the change operation occurred "coll" : "<collection>" // The collection where the change operation occurred }, "to" : { // These fields are displayed only when the operation type is 'rename' "db" : "<database>", // The new database name after the change "coll" : "<collection>" // The new collection name after the change }, "source":{ "ts_ms":"<timestamp>", // The timestamp when the change operation occurred "table":"<collection>" // The collection where the change operation occurred "db":"<database>", // The database where the change operation occurred "snapshot":"false" // Identify the current stage of data synchronization }, "documentKey" : { "_id" : <value> }, // The _id field value of the document involved in the change operation "updateDescription" : { // Description of the update operation "updatedFields" : { <document> }, // The fields and values that the update operation modified "removedFields" : [ "<field>", ... ] // The fields and values that the update operation removed } "clusterTime" : <Timestamp>, // The timestamp of the Oplog log entry corresponding to the change operation "txnNumber" : <NumberLong>, // If the change operation is executed in a multi-document transaction, this field and value are displayed, representing the transaction number "lsid" : { // Represents information related to the Session in which the transaction is located "id" : <UUID>, "uid" : <BinData> } } ``` CDC Compatible Debezium-jsonformat not supports mongodb. -- 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]
