Duplicate entry 'xxxx' for key

[sdojjy]

table schema

create table handle_records (
id varbinary(16) NOT NULL,
store_id varbinary(16) default null,
source_type varchar(255) default null,
source_id varbinary(16) default null,
handle varchar(255) default null,
Primary key(id),
unique key unique_index_handle_records_on_handle(store_id, handle, source_type)
)engine=innoDB default charset=utf8mb4

existing data

MySQL root@127.0.0.1:test> select * from handle_records;
+----+------------------+-------------+-----------+--------+
| id | store_id         | source_type | source_id | handle |
+----+------------------+-------------+-----------+--------+
| e  | 0x5942c803664b00 | x           | <null>    | c      |
| f  | 0x5942c803664b00 | d           | <null>    | c      |
+----+------------------+-------------+-----------+--------+

The transaction on upstream

begin;
update handle_records set source_type = 'x' where id = 'e';
insert into handle_records(id, store_id, handle, source_type) values ('f', 0x5942C803664B00, 'c',  'd');
commit;

when batch dml is enable , cdc will execute transaction like

begin;
insert into handle_records(id, store_id, handle, source_type) values ('f', 0x5942C803664B00, 'c',  'd');
update handle_records set source_type = 'x' where id = 'e';
commit;