flinkcdc同步oceanbase数据到kafka报错

【 使用环境 】生产环境
【版本】v4.2.1.3
【问题描述】用mysql-cdc的方式设置oceanbase作为源表,flink任务运行两分钟后报错cannot read the binlog filename and position via ‘show master status’,ob用户已给REPLICATION相关权限,用mysql客户端登陆oceanbase后执行show master status报错You have an error in your SQL syntax; check the manual that corresponds to your OceanBase version for the right syntax to use near
‘master status’ at line 1,请问是什么问题

不是用ob的binlog么?

是连接他人的ob,能用sql查看是否使用binlog模式吗,我执行show variables like '%log_bin%'结果是on

你这个工具不支持OB吧?OB虽然语法跟MySQL像,但日志格式跟MySQL是不一样的。可以用oms

主要不是ob的工具 这个应该有问题 建议使用obbinlog工具转化为mysql的binlog日志 在接下游的工具

1 个赞