【 使用环境 】生产环境 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
【问题描述】清晰明确描述问题
【复现路径】问题出现前后相关操作
【附件及日志】
麻烦大佬解决下
使用的 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的配置文件