search

pingcap / tiflow

This repo maintains DM (a data migration platform) and TiCDC (change data capture for TiDB)
Apache License 2.0
423 stars 281 forks source link

the maxwell delete data is different from maxwells-deamon's dataformat #8159

Open Sparsamkeit opened 1 year ago

Sparsamkeit commented 1 year ago

What did you do?

i use maxwell protocol to sink to kafka, and i use flink-connector kafka with maxwell-json format to connect.

What did you expect to see?

i should see delete data.

i found the delete data from ticdc is on the 'old' key, but in the maxwells-deamon it shows that delete data should on the 'data' key.

What did you see instead?

i didn't get delete data

Versions of the cluster

Upstream TiDB cluster version (execute SELECT tidb_version(); in a MySQL client):

4.0.16

Upstream TiKV version (execute tikv-server --version):

4.0.16

TiCDC version (execute cdc version):

v4.0.16
fubinzh commented 1 year ago

/severity moderate

asddongmen commented 3 months ago

Since maxwell protocol is not a GA feature in TiCDC, so we consider this is not a bug.