【 使用环境 】测试环境
【 OB or 其他组件 】
【 使用版本 】OB:4.2.1.1 oblogproxy-ce:2.0.2
【问题描述】
如图flink 日志反复提示 已连接oblogproxy，然后断开，重连超时。
oblogproxy 日志也没有更多提示，只是显示断开。
经测试，java代码直连oblogproxy 无断开问题，能正常收到event事件的message，就是flink 无法监听oblogproxy。
如图flink 日志反复提示 已连接oblogproxy，然后断开，重连超时。
oblogproxy 日志也没有更多提示，只是显示断开。
1 个赞
Flink CDC 的 OB Connector 里其实用的也是 oblogclient，所以用 Flink CDC 和直接用客户端 SDK 理论上应该表现是一样的。没有报错这个还挺奇怪的，Flink CDC 用的是哪个版本？有没有连接超时、网络不通的可能？
1 个赞
flink 1.17
cdc 3.1.1
跟代码oblog client 用的同样的 连接参数，用户名，密码。
就是不行。
日志显示他都能获取到监听的数据库、表名，说明flink 连接 ob 链路正常。
日志显示他能connected 到oblogproxy ，说明flink连接 oblogproxy 链路也正常。
哪里还能看到更多详细的日志？
1 个赞
Flink 这边的日志信息应该就这些了，oblogproxy 那边的日志里信息会更多一些，不过我看你上面的贴图，刨除 clog check 这些无关告警，似乎是客户端主动进行了关闭。麻烦把 logproxy 和对应 client id 的 logreader 的日志发上来看看。
另外，我想到一点， 3.2.0 之前的 logProxyClient 的异常处理有问题，会把 onException 的输入吞掉，虽然按我的理解相关性不大，不过你可以试一下 3.2.0 或者更新的 cdc 包。
1 个赞