从canal-adapter日志里能看到消费到了DML，但是目标数据库没有执行

2021-05-31 14:33:07.116 [Thread-4] INFO c.a.otter.canal.adapter.launcher.loader.AdapterProcessor - =============> Subscribe destination: instance01 succeed <============= 2021-05-31 14:33:07.798 [pool-9-thread-1] INFO c.a.o.canal.client.adapter.logger.LoggerAdapterExample - DML: {"data":[{"id":8,"cluster_id":1,"name":"null","ip":"10.244.5.5","admin_port":11110,"tcp_port":11111,"metric_port":11112,"status":"-1","modified_time":1622168415000}],"database":"canal_manager","destination":"instance01","es":1622197214000,"groupId":"g1","isDdl":false,"old":null,"pkNames":["id"],"sql":"","table":"canal_node_server","ts":1622442787686,"type":"INSERT"} 2021-05-31 14:33:07.798 [pool-9-thread-1] INFO c.a.o.canal.client.adapter.logger.LoggerAdapterExample - DML: {"data":null,"database":"canal_manager","destination":"instance01","es":1622197295000,"groupId":"g1","isDdl":true,"old":null,"pkNames":null,"sql":"create table d( a int)","table":"d","ts":1622442787717,"type":"CREATE"} 2021-05-31 14:33:07.799 [pool-9-thread-1] INFO c.a.o.canal.client.adapter.logger.LoggerAdapterExample - DML: {"data":[{"id":6,"cluster_id":1,"name":"canal01","ip":"10.244.2.15","admin_port":11110,"tcp_port":11111,"metric_port":11112,"status":"-1","modified_time":1622168566000}],"database":"canal_manager","destination":"instance01","es":1622197365000,"groupId":"g1","isDdl":false,"old":[{"ip":"10.244.5.23","modified_time":1622167241000}],"pkNames":["id"],"sql":"","table":"canal_node_server","ts":1622442787717,"type":"UPDATE"} 2021-05-31 14:33:07.799 [pool-9-thread-1] INFO c.a.o.canal.client.adapter.logger.LoggerAdapterExample - DML: {"data":[{"id":8,"cluster_id":1,"name":"null","ip":"10.244.5.5","admin_port":11110,"tcp_port":11111,"metric_port":11112,"status":"-1","modified_time":1622168415000}],"database":"canal_manager","destination":"instance01","es":1622197375000,"groupId":"g1","isDdl":false,"old":null,"pkNames":["id"],"sql":"","table":"canal_node_server","ts":1622442787718,"type":"DELETE"} 2021-05-31 14:33:07.799 [pool-9-thread-1] INFO c.a.o.canal.client.adapter.logger.LoggerAdapterExample - DML: {"data":null,"database":"canal_manager","destination":"instance01","es":1622197400000,"groupId":"g1","isDdl":true,"old":null,"pkNames":null,"sql":"create table e( a int)","table":"e","ts":1622442787718,"type":"CREATE"} 2021-05-31 14:45:18.917 [pool-9-thread-1] INFO c.a.o.canal.client.adapter.logger.LoggerAdapterExample - DML: {"data":[{"id":1}],"database":"canal_manager","destination":"instance01","es":1622443518000,"groupId":"g1","isDdl":false,"old":null,"pkNames":[],"sql":"","table":"a","ts":1622443518917,"type":"INSERT"}

原提问者GitHub用户jiangxiaoqiang