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
看下canal.properties的canal.serverMode参数值是不是 canal.serverMode = kafka(默认是tcp)
原回答者GitHub用户xuranyang
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。