Thank you. I will try and reply soon.
Best Regards, Dongcheol Gong 2020년 1월 3일 (금) 오후 6:09, [email protected] <[email protected]>님이 작성: > > 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 <[email protected]> > *Date:* 2020-01-03 13:51 > *To:* users <[email protected]> > *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. > >
