hailin
/
rwadurian
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(deploy-mining): 预拉取 Kafka CLI 镜像避免 timeout 期间拉取失败 

standalone 模式下 run_kafka_cmd 使用 docker run confluentinc/cp-kafka:7.5.0，
首次运行时镜像未缓存导致 docker pull 被 timeout 30 截断，循环重试卡住。
添加 ensure_kafka_image() 在执行命令前先确保镜像已拉取。

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
hailin 2026-02-01 22:36:38 -08:00
parent d53c2212a6
commit 0156be8d25
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
backend/services/deploy-mining.sh
View File

@ -330,13 +330,21 @@ run_psql() {
# =========================================================================== # ===========================================================================
# Helper: Execute Kafka admin command (auto-detect Docker or remote) # Helper: Execute Kafka admin command (auto-detect Docker or remote)
# =========================================================================== # ===========================================================================
ensure_kafka_image() {
local image="confluentinc/cp-kafka:7.5.0"
if ! docker image inspect "$image" &>/dev/null; then
log_info "Pulling Kafka CLI image: $image (first time only)..."
docker pull "$image"
fi
}
run_kafka_cmd() { run_kafka_cmd() {
local cmd="$1" local cmd="$1"
shift shift
if [ "$DEPLOY_MODE" = "standalone" ]; then if [ "$DEPLOY_MODE" = "standalone" ]; then
# Standalone: Kafka is remote, use temporary container with host networking # Standalone: Kafka is remote, use temporary container with host networking
# Add timeout to prevent hangs when Kafka is unreachable across servers ensure_kafka_image
timeout 30 docker run --rm --network host confluentinc/cp-kafka:7.5.0 \ timeout 30 docker run --rm --network host confluentinc/cp-kafka:7.5.0 \
$cmd --bootstrap-server "$KAFKA_BROKERS" "$@" $cmd --bootstrap-server "$KAFKA_BROKERS" "$@"
return $? return $?
@ -364,6 +372,7 @@ run_kafka_cmd_stdin() {
shift shift
if [ "$DEPLOY_MODE" = "standalone" ]; then if [ "$DEPLOY_MODE" = "standalone" ]; then
ensure_kafka_image
timeout 30 docker run --rm -i --network host confluentinc/cp-kafka:7.5.0 \ timeout 30 docker run --rm -i --network host confluentinc/cp-kafka:7.5.0 \
$cmd --bootstrap-server "$KAFKA_BROKERS" "$@" $cmd --bootstrap-server "$KAFKA_BROKERS" "$@"
return $? return $?