From 63a169abb01ba5e00d26b004fd90a20885b41414 Mon Sep 17 00:00:00 2001 From: hailin Date: Thu, 26 Feb 2026 18:58:49 -0800 Subject: [PATCH] =?UTF-8?q?fix(cdc):=20deploy-mining.sh=20=E6=B7=BB?= =?UTF-8?q?=E5=8A=A0=E9=A2=84=E7=A7=8DCDC=20connector=E7=AE=A1=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 更新 CDC_POSTGRES_CONNECTORS 数组和所有 case 映射（resnapshot、 full-reset topic清理、Step9重注册），确保2.0部署脚本能正确 管理预种CDC connector的生命周期。 Co-Authored-By: Claude Opus 4.6 --- backend/services/deploy-mining.sh | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/backend/services/deploy-mining.sh b/backend/services/deploy-mining.sh index 8c6a6824..006e61d6 100755 --- a/backend/services/deploy-mining.sh +++ b/backend/services/deploy-mining.sh @@ -148,6 +148,8 @@ CDC_POSTGRES_CONNECTORS=( "identity-postgres-connector" "referral-postgres-connector" "planting-postgres-connector" + # [2026-02-27] 新增：3171预种计划CDC（同rwa_planting库，独立slot/publication/topic） + "pre-planting-postgres-connector" ) # Colors @@ -990,6 +992,9 @@ cdc_resnapshot() { "planting-postgres-connector") config_file="$scripts_dir/planting-connector.json" ;; + "pre-planting-postgres-connector") + config_file="$scripts_dir/pre-planting-connector.json" + ;; esac if [ -n "$config_file" ] && [ -f "$config_file" ]; then @@ -1463,6 +1468,7 @@ full_reset() { "identity-postgres-connector") topic_prefix="cdc.identity" ;; "referral-postgres-connector") topic_prefix="cdc.referral" ;; "planting-postgres-connector") topic_prefix="cdc.planting" ;; + "pre-planting-postgres-connector") topic_prefix="cdc.pre-planting" ;; esac if [ -n "$topic_prefix" ]; then @@ -1598,6 +1604,7 @@ full_reset() { "identity-postgres-connector") config_file="$scripts_dir/identity-connector.json" ;; "referral-postgres-connector") config_file="$scripts_dir/referral-connector.json" ;; "planting-postgres-connector") config_file="$scripts_dir/planting-connector.json" ;; + "pre-planting-postgres-connector") config_file="$scripts_dir/pre-planting-connector.json" ;; esac if [ -n "$config_file" ] && [ -f "$config_file" ]; then