开发者社区> 问答> 正文

canal一直处于the next step is binlog dump的状态,怎么处理?

meta.log中显示已经读取到了283190027的position,但是实例中日志显示position=283091189,并且一直处于the next step is binlog dump的状态,就是不进行binlog的读取,kafka也没有消息,这个需要怎么处理,求大佬解惑

cat meta.log 2021-07-19 09:52:43.260 - clientId:1001 cursor:[mysql-bin.000001,283183958,1626659562000,12,] address[47.106.241.38/47.106.241.38:20717] 2021-07-19 09:52:53.260 - clientId:1001 cursor:[mysql-bin.000001,283184825,1626659572000,12,] address[47.106.241.38/47.106.241.38:20717] 2021-07-19 09:53:03.260 - clientId:1001 cursor:[mysql-bin.000001,283185692,1626659582000,12,] address[47.106.241.38/47.106.241.38:20717] 2021-07-19 09:53:13.260 - clientId:1001 cursor:[mysql-bin.000001,283186559,1626659592000,12,] address[47.106.241.38/47.106.241.38:20717] 2021-07-19 09:53:23.260 - clientId:1001 cursor:[mysql-bin.000001,283187426,1626659602000,12,] address[47.106.241.38/47.106.241.38:20717] 2021-07-19 09:53:33.260 - clientId:1001 cursor:[mysql-bin.000001,283188293,1626659612000,12,] address[47.106.241.38/47.106.241.38:20717] 2021-07-19 09:53:43.260 - clientId:1001 cursor:[mysql-bin.000001,283189160,1626659622000,12,] address[47.106.241.38/47.106.241.38:20717] 2021-07-19 09:53:53.260 - clientId:1001 cursor:[mysql-bin.000001,283190027,1626659632000,12,] address[47.106.241.38/47.106.241.38:20717]

cat billing.log 2021-07-19 09:45:53.164 [main] DEBUG c.a.o.c.i.spring.support.PropertyPlaceholderConfigurer - Loading properties file from class path resource [canal.properties] 2021-07-19 09:45:53.167 [main] DEBUG c.a.o.c.i.spring.support.PropertyPlaceholderConfigurer - Loading properties file from class path resource [billing/instance.properties] 2021-07-19 09:45:53.167 [main] INFO c.a.o.c.i.spring.support.PropertyPlaceholderConfigurer - Properties resource not found: class path resource [billing/instance.properties] cannot be opened because it does not exist 2021-07-19 09:45:53.196 [main] DEBUG c.a.o.c.i.spring.support.PropertyPlaceholderConfigurer - Loading properties file from class path resource [canal.properties] 2021-07-19 09:45:53.197 [main] DEBUG c.a.o.c.i.spring.support.PropertyPlaceholderConfigurer - Loading properties file from class path resource [billing/instance.properties] 2021-07-19 09:45:53.197 [main] INFO c.a.o.c.i.spring.support.PropertyPlaceholderConfigurer - Properties resource not found: class path resource [billing/instance.properties] cannot be opened because it does not exist 2021-07-19 09:45:53.259 [main] INFO c.a.otter.canal.instance.spring.CanalInstanceWithSpring - start CannalInstance for 1-billing 2021-07-19 09:45:53.260 [main] WARN c.a.o.canal.parse.inbound.mysql.dbsync.LogEventConvert - --> init table filter : ^billing..*$ 2021-07-19 09:45:53.260 [main] WARN c.a.o.canal.parse.inbound.mysql.dbsync.LogEventConvert - --> init table black filter : 2021-07-19 09:45:53.262 [main] INFO c.a.otter.canal.instance.core.AbstractCanalInstance - start successful.... 2021-07-19 09:45:53.870 [destination = billing , address = /47.106.241.38:20717 , EventParser] WARN c.a.o.c.p.inbound.mysql.rds.RdsBinlogEventParserProxy - ---> begin to find start position, it will be long time for reset or first position 2021-07-19 09:45:53.872 [destination = billing , address = /47.106.241.38:20717 , EventParser] WARN c.a.o.c.p.inbound.mysql.rds.RdsBinlogEventParserProxy - prepare to find start position just last position {"identity":{"slaveId":-1,"sourceAddress":{"address":"47.106.241.38","port":20717}},"postion":{"gtid":"","included":false,"journalName":"mysql-bin.000001","position":283091189,"serverId":12,"timestamp":1626658097000}} 2021-07-19 09:45:54.289 [destination = billing , address = /47.106.241.38:20717 , EventParser] WARN c.a.o.c.p.inbound.mysql.rds.RdsBinlogEventParserProxy - ---> find start position successfully, EntryPosition[included=false,journalName=mysql-bin.000001,position=283091189,serverId=12,gtid=,timestamp=1626658097000] cost : 417ms , the next step is binlog dump

原提问者GitHub用户tryniyijiao

展开
收起
山海行 2023-04-27 16:19:18 273 0
1 条回答
写回答
取消 提交回答
  • 看下canal.properties的canal.serverMode参数值是不是 canal.serverMode = kafka(默认是tcp)

    原回答者GitHub用户xuranyang

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

相关电子书

更多
PolarDB-X 2.0 全局 Binlog 与备份恢复能 立即下载
低代码开发师(初级)实战教程 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载