CDC data inconsistency after injection network partition between all cdc and all kafka

[Lily2025]

What did you do?

1、downstream：kafka
2、run sysbench and cdc_boundary
3、inject network partition between all cdc and all kafka lasts for 10mins
4、recover fault

What did you expect to see?

data consistency

What did you see instead?

CDC data inconsistency when injection some fault
�[3A�[JComparing the table data of sysbench_64_7000w.sbtest39 ... failure

---

Progress [============================================================>] 100% 0/0
�[1A�[JProgress [============================================================>] 100% 0/0
The data of sysbench_64_7000w.sbtest39 is not equal
The rest of tables are all equal.

Versions of the cluster

./cdc version
Release Version: v8.1.2
Git Commit Hash: 0c88977
Git Branch: HEAD
UTC Build Time: 2024-12-17 04:31:18
Go Version: go version go1.21.13 linux/amd64
Failpoint Build: false
2024-12-19T11:07:37.891+0800

current status of DM cluster (execute query-status <task-name> in dmctl)

No response

[Lily2025]

/severity critical
/assign hicqu