【TiDB 使用环境】 测试环境
【TiDB 版本】
tidb 组件版本7.5.3
ticdc 版本8.5.6 未开启新架构
【集群数据量】
两套3PD +3Kv +3 tidb 通过ticdc 做同步
【遇到的问题】
重启ticdc 时候会报错
[CDC:ErrInvalidEtcdKey] invalid key: /meta/ticdc-delete-etcd-key-count
ai 辅助分析源码说是 ticdc 会写入这个 ticdc-delete-etcd-key-count 这个key
但是在/etcd/etcdky.go Parse 中又没有定义这个是合法key
func (k *CDCKey) Parse(clusterID, key string) error {
if !strings.HasPrefix(key, clusterPrefix(clusterID)) {
return errors.ErrInvalidEtcdKey.GenWithStackByArgs(key)
}
key = key[len(cdcKeyRoot):]
parts := strings.Split(key, "/")
k.ClusterID = parts[1]
key = key[len(k.ClusterID)+1:]
if strings.HasPrefix(key, metaPrefix) {
key = key[len(metaPrefix):]
switch {
case strings.HasPrefix(key, ownerKey):
k.Tp = CDCKeyTypeOwner
k.CaptureID = ""
key = key[len(ownerKey):]
if len(key) > 0 {
key = key[1:]
}
k.OwnerLeaseID = key
case strings.HasPrefix(key, captureKey):
k.Tp = CDCKeyTypeCapture
k.CaptureID = key[len(captureKey)+1:]
k.OwnerLeaseID = ""
case strings.HasPrefix(key, metaVersionKey):
k.Tp = CDCKeyTypeMetaVersion
default:
return errors.ErrInvalidEtcdKey.GenWithStackByArgs(key)
}
开启新架构会跳过这个key的解析
有遇到相同情况的吗