开发者社区> 问答> 正文

修改mysql 行记录数据,adapter 有监测到数据变更,但并没有同步到es

我检查我的数据库是开启的,但是还是同样的问题,修改mysql 行记录数据,adapter 有监测到数据变更,但并没有同步到es,日志没有报错

2019-10-10 10:15:31.814 [Thread-26] INFO c.a.o.canal.adapter.launcher.loader.CanalAdapterWorker - =============> Start to connect destination: example <============= 2019-10-10 10:15:31.816 [main] INFO c.a.o.canal.adapter.launcher.loader.CanalAdapterLoader - Start adapter for canal instance: example succeed 2019-10-10 10:15:36.705 [main] INFO c.a.o.canal.adapter.launcher.loader.CanalAdapterService - ## the canal client adapters are running now ...... 2019-10-10 10:15:36.721 [main] INFO org.apache.coyote.http11.Http11NioProtocol - Starting ProtocolHandler ["http-nio-8081"] 2019-10-10 10:15:36.724 [main] INFO org.apache.tomcat.util.net.NioSelectorPool - Using a shared selector for servlet write/read 2019-10-10 10:15:36.749 [main] INFO o.s.boot.web.embedded.tomcat.TomcatWebServer - Tomcat started on port(s): 8081 (http) with context path '' 2019-10-10 10:15:36.753 [main] INFO c.a.otter.canal.adapter.launcher.CanalAdapterApplication - Started CanalAdapterApplication in 54.174 seconds (JVM running for 57.087) 2019-10-10 10:15:36.762 [Thread-26] INFO c.a.o.canal.adapter.launcher.loader.CanalAdapterWorker - =============> Start to subscribe destination: example <============= 2019-10-10 10:15:36.765 [Thread-26] INFO c.a.o.canal.adapter.launcher.loader.CanalAdapterWorker - =============> Subscribe destination: example succeed <============= 2019-10-10 10:15:50.622 [pool-2-thread-1] INFO c.a.o.canal.client.adapter.logger.LoggerAdapterExample - DML: {"data":[{"INFOID":"04B7F026-F8A7-4419-A9BA-C807A4601D58","RESNAME":"对讲机7","RESCODE":"201909291010444780","TITLE":"","RESTYPE":1,"COPYRIGHT":"广州欧科信息技术股份有限公司","DESCRIPT":"","PUBUSER":"","PUBDT":null,"INFOSRC":19,"RECSTATUS":0,"AUDITUSER":"","AUDITDT":null,"AUDITIDEA":"","PHOTOGRAPUSER":"","PHOTOGRAPPLACE":"","PHOTOGRAPDT":"2016-07-22 10:21:32","DEVICE":"Canon EOS 5D Mark II","HELPER":"","MAKE":"","CREATOR":"1","CTIME":1569723288000,"EDITOR":"","ETIME":null,"BROWSECOUNT":0,"COLLECTCOUNT":0,"DOWNCOUNT":0,"REMARK":"","RESCLASS":""}],"database":"prodplus","destination":"example","es":1570673749000,"groupId":null,"isDdl":false,"old":[{"RESNAME":"对讲机2"}],"pkNames":["INFOID"],"sql":"","table":"dr_resinfo","ts":1570673750309,"type":"UPDATE"}

请问有什么办法定位到问题出现在哪么?

原提问者GitHub用户Ecli2h

展开
收起
Java工程师 2023-05-03 16:17:33 168 0
1 条回答
写回答
取消 提交回答
  • 这里有解决方法,https://github.com/alibaba/canal/issues/3144,我最开始是看漏了adapter日志中的报错信息,Canal Adapter com.alibaba.druid.pool.DruidDataSource cannot be cast to com.alibaba.druid.pool.DruidDataSource,看看是不是有这个报错

    原回答者GitHub用户u19900101

    2023-05-04 17:59:11
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
搭建电商项目架构连接MySQL 立即下载
搭建4层电商项目架构,实战连接MySQL 立即下载
PolarDB MySQL引擎重磅功能及产品能力盛大发布 立即下载

相关镜像