fix cdc (#1643)

Co-authored-by: ti-chi-bot[bot] <108142056+ti-chi-bot[bot]@users.noreply.github.com>
pingcap · Feb 19, 2024 · 43fe8da · 43fe8da
1 parent e1daa54
commit 43fe8da
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/pkg/utils/topology/ticdc.go b/pkg/utils/topology/ticdc.go
@@ -19,8 +19,7 @@ import (
 
 // TODO: refactor this with topology prefix since it is compatible with other components.
 const (
-	ticdcTopologyKeyPrefix = "/tidb/cdc/"
-	ticdcCaptureKeyIdent   = "__cdc_meta__/capture/"
+	ticdcTopologyKeyPrefix = "/topology/ticdc/"
 )
 
 func FetchTiCDCTopology(ctx context.Context, etcdClient *clientv3.Client) ([]TiCDCInfo, error) {
@@ -35,7 +34,7 @@ func FetchTiCDCTopology(ctx context.Context, etcdClient *clientv3.Client) ([]TiC
 	nodes := make([]TiCDCInfo, 0)
 	for _, kv := range resp.Kvs {
 		key := string(kv.Key)
-		if !strings.HasPrefix(key, ticdcTopologyKeyPrefix) || !strings.Contains(key, ticdcCaptureKeyIdent) {
+		if !strings.HasPrefix(key, ticdcTopologyKeyPrefix) {
 			continue
 		}