diff --git a/backend/services/deploy-mining.sh b/backend/services/deploy-mining.sh index 084024d9..8c6a6824 100755 --- a/backend/services/deploy-mining.sh +++ b/backend/services/deploy-mining.sh @@ -275,6 +275,8 @@ load_env() { export DEBEZIUM_DB_HOST="postgres-2" # MPC system 在 1.0 服务器上 export MPC_ACCOUNT_SERVICE_URL="${MPC_ACCOUNT_SERVICE_URL:-http://192.168.1.111:4000}" + # 1.0 Debezium Connect URL (source CDC connectors 在 1.0 服务器上) + DEBEZIUM_1_CONNECT_URL="${DEBEZIUM_1_CONNECT_URL:-http://192.168.1.111:8084}" POSTGRES_CONTAINER="${POSTGRES_CONTAINER:-rwa-postgres-2}" KAFKA_CONTAINER="" # Kafka is remote, no local container @@ -904,7 +906,12 @@ sync_reset() { cdc_resnapshot() { print_section "Triggering CDC Connectors Re-Snapshot" + # Source CDC connectors 在 1.0 Debezium 上 local connect_url="$DEBEZIUM_CONNECT_URL" + if [ "$DEPLOY_MODE" = "standalone" ]; then + connect_url="$DEBEZIUM_1_CONNECT_URL" + log_info "Standalone mode: targeting 1.0 Debezium at $connect_url" + fi # Check if Debezium Connect is available if ! curl -s "$connect_url" &>/dev/null; then