Make sure you have turn on the row format binlog.
In my case, the insert statement will have the following bin log result:
### INSERT INTO `athena`.`t_api_msg`
### SET
### @1=40265204
### @2=NULL
### @3='W001'
### @4='WMS'
Thanks,
Lei
From: DC Gong
Date: 2020-01-03 13:51
To: users
Subject: CaptureChangeMySQL cannot capture INSERT,UPDATE,DELETE
Hello,
I've finished setting up CaptureChangeMySQL but I can't capture INSERT, UPDATE
and DELETE
However, DDL, begin, and commit are normally captured.
I don't know what the problem is.
I am using mariadb and I have used both mariadb jdbc driver and mysql jdbc
driver, both of which do not work.
When i run the INSERT statement, the DEBUG log of CaptureChangeMySQL is as
shown below, and only Begin and Commit are being captured.
2020-01-03 14:35:42,200 DEBUG [Timer-Driven Process Thread-5]
o.a.n.c.m.processors.CaptureChangeMySQL
CaptureChangeMySQL[id=69ae3ed7-016f-1000-ffff-ffffc79929dc] Setting CLUSTER
State to {cdc.sequence.id=6, binlog.filename=master1-bin.000004,
binlog.position=1805}
2020-01-03 14:35:43,030 DEBUG [Timer-Driven Process Thread-7]
o.a.n.c.m.processors.CaptureChangeMySQL
CaptureChangeMySQL[id=69ae3ed7-016f-1000-ffff-ffffc79929dc] Got message event
type: QUERY
2020-01-03 14:35:43,030 DEBUG [Timer-Driven Process Thread-7]
o.a.n.c.m.processors.CaptureChangeMySQL
CaptureChangeMySQL[id=69ae3ed7-016f-1000-ffff-ffffc79929dc] Got message event
type: QUERY
2020-01-03 14:35:43,030 DEBUG [Timer-Driven Process Thread-7]
o.a.n.c.m.processors.CaptureChangeMySQL
CaptureChangeMySQL[id=69ae3ed7-016f-1000-ffff-ffffc79929dc] Got message event
type: XID
The binlogs in mariadb are as follows.
#200103 14:33:04 server id 1 end_log_pos 1292 CRC32 0x253f591a GTID
0-1-33 trans
/*!100001 SET @@session.gtid_seq_no=33*//*!*/;
BEGIN
/*!*/;
# at 1292
#200103 14:33:04 server id 1 end_log_pos 1404 CRC32 0x21499287 Query
thread_id=13 exec_time=0 error_code=0
SET TIMESTAMP=1578029584/*!*/;
/*!\C utf8 *//*!*/;
SET
@@session.character_set_client=33,@@session.collation_connection=33,@@session.collation_server=8/*!*/;
INSERT INTO ggong_table values(4, '33')
/*!*/;
# at 1404
#200103 14:33:04 server id 1 end_log_pos 1435 CRC32 0x76c65582 Xid = 61
COMMIT/*!*/;
I want you guys to help me.
