TiKV 报错 cdc initialize fail: Sink send error Disconnected

【 TiDB 使用环境】生产环境
【 TiDB 版本】v5.4.2

TiKV 报错这个错误是什么情况呀?是下游有问题嘛?

cdc任务创建有报错吗?

没有报错,我们没有使用 ticdc,使用的是 client-java 获取的 cdc 事件。

此时下游的 cdc 任务还有数据推送,但我理解应该推送的是其他 region 上的增量数据,而报错的这些 region 上的数据应该是拿不到了吧?

:+1: 是用 java 写一个 cdc 吗?可以分享一下吗 :grinning:? 可以参考 专栏 - TiCDC 源码解读(6)- TiCDC Puller 模块介绍 | TiDB 社区 这篇文章来做一些错误处理和region 重连工作。

谢谢大佬的分享的文章,java实现的 tidb-cdc,其实就是这个项目,https://github.com/tikv/client-java/blob/release-3.2/src/main/java/org/tikv/cdc/CDCClient.java

图中错误的原因是下游 CDC 提前把链接断开了,是非预期的。java 版本的 CDCClient 没经过大量测试,尚不成熟。 建议使用 TiCDC https://docs.pingcap.com/zh/tidb/stable/ticdc-overview。