开发者社区> 问答> 正文

从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

展开
收起
山海行 2023-04-27 16:38:21 126 0
1 条回答
写回答
取消 提交回答
  • 没有配置mytest_user.yaml表映射,配置了就可以同步了

    原回答者GitHub用户jiangxiaoqiang

    2023-04-27 22:32:54
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
DTCC 2022大会集锦《云原生一站式数据库技术与实践》 立即下载
阿里云瑶池数据库精要2022版 立即下载
2022 DTCC-阿里云一站式数据库上云最佳实践 立即下载