Skip to content

[Feature][S3-Sink] Improve maxwell_json,canal_json,debezium_json format #9773

@wubx

Description

@wubx

Search before asking

  • I had searched in the feature and found no similar feature requirement.

Description

Thanks #9701
After this pr insert,delete work fine.

but

 update t01 set c1='test' where id=7;

Was split into two records and ts as same.

{"data":{"id":7,"c1":"debezium_json10"},"type":"DELETE","database":"wubx","table":"t01","ts":1756197561415}
{"data":{"id":7,"c1":"test"},"type":"INSERT","database":"wubx","table":"t01","ts":1756197561415}

It is impossible to distinguish which one occurred later based on time here.

Is it possible to simply record this as a "type: update"?

{"data":{"id":7,"c1":"test"},"type":"update","before":{"id":7,"c1":"debezium_json10}, "database":"wubx","table":"t01","ts":1756197561415}

Usage Scenario

No response

Related issues

No response

Are you willing to submit a PR?

  • Yes I am willing to submit a PR!

Code of Conduct

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions