flinkcdc 采集oceabase 到kafka 。oblogreader报错 ,求助!!!!!

【 使用环境 】生产环境 or 测试环境
【 OB or 其他组件 】
【 使用版本 】flink1.15.3 flink-sql-connector-oceanbase-cdc-2.2.0 oceanbase-all-in-one-4.2.1.3 oblogproxy-2.0.0
【问题描述】清晰明确描述问题
【复现路径】问题出现前后相关操作
【附件及日志】

libobcdc.log

麻烦大佬解决下

使用的 obcdc,不是用的oblogproxy的cdc模式是吧

替换成 oblogproxy试试吧,不要用obcdc了

用的是flinkcdc

相关版本flink1.15.3 flink-sql-connector-oceanbase-cdc-2.2.0 oceanbase-all-in-one-4.2.1.3 oblogproxy-2.0.0

具体操作有没有相关文档呀

老师,这个怎么处理哇

参考下这篇文档?obcdc和oblogproxy都是增量日志拉取服务,把obcdc替换成oblogproxy就可以

https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000000217993

那我就是用的oblogproxy oblogproxy-2.0.0

/usr/local/oblogproxy/run/10.10.101.64_29551_1705904545mq_t1.test_ob_to_kakfa.tbl1/log
日志查看路径

老师能看出来是什么问题吗

你的日志不是libobcdc吗?这个跟oblogproxy是两个东西


我就是这样安装的,是我日志看错了吗

发一下oblogproxy的配置文件

oblogproxy配置文件


新出现的问题: