canal 1.1.8版本
binlog 服务 4.2.0版本
canal Mysql 版去连接 oceanbase， example 日志显示
2025-04-30 09:33:41.845 [main] INFO c.a.otter.canal.instance.spring.CanalInstanceWithSpring - start CannalInstance for 1-example
2025-04-30 09:33:42.335 [main] WARN c.a.o.canal.parse.inbound.mysql.dbsync.LogEventConvert - → init table filter : ^test…$
2025-04-30 09:33:42.335 [main] WARN c.a.o.canal.parse.inbound.mysql.dbsync.LogEventConvert - → init table black filter : ^mysql.slave_.$
2025-04-30 09:33:42.339 [main] INFO c.a.otter.canal.instance.core.AbstractCanalInstance - start successful…
2025-04-30 09:33:43.666 [destination = example , address = /127.0.0.1:2883 , 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
2025-04-30 09:33:43.666 [destination = example , address = /127.0.0.1:2883 , EventParser] WARN c.a.o.c.p.inbound.mysql.rds.RdsBinlogEventParserProxy - prepare to find start position just show master status
2025-04-30 09:33:43.764 [destination = example , address = /127.0.0.1:2883 , EventParser] WARN c.a.otter.canal.parse.inbound.mysql.MysqlConnection - load MySQL @@version_comment : OceanBase_CE 4.3.5.0 (r100000202024123117-5d6cb5cbc3f7c1ab6eb22e40abec8e160a8764d5) (Built Dec 31 2024 17:34:49)
2025-04-30 09:33:44.150 [destination = example , address = /127.0.0.1:2883 , EventParser] WARN c.a.o.c.p.inbound.mysql.rds.RdsBinlogEventParserProxy - —> find start position successfully, EntryPosition[included=false,journalName=mysql-bin.000023,position=78347,serverId=8357945,gtid=,timestamp=1745853282000] cost : 477ms , the next step is binlog dump
2025-04-30 09:33:44.209 [destination = example , address = /127.0.0.1:2883 , EventParser] WARN c.a.otter.canal.parse.inbound.mysql.MysqlConnection - load MySQL @@version_comment : OceanBase_CE 4.3.5.0 (r100000202024123117-5d6cb5cbc3f7c1ab6eb22e40abec8e160a8764d5) (Built Dec 31 2024 17:34:49)
conf/example/meta.dat 中的内容是这样的
{“clientDatas”:[{“clientIdentity”:{“clientId”:1001,“destination”:“example”,“filter”:""}}],“destination”:“example”}
在 oceanbase 中插入数据之后，show master status 查看Position 数字在变，但是 canal 拿不到数据，而且conf/example/meta.dat 的内容也没有更新；而使用 flink cdc 的 Mysql 模式连同样的地址，却能拿到数据