修改配置

03-start-infra.sh

@@ -63,36 +63,42 @@ start_docker_logger "dev-redis"
 step "Kafka (KRaft)"
 
 if docker ps --format '{{.Names}}' | grep -q '^dev-kafka$'; then
-  success "Kafka 已在运行 (container=dev-kafka) :${KAFKA_PORT}"
+  success "Kafka 已在运行 (container=dev-kafka) 本机 :${KAFKA_PORT}  外网 ${DEPLOY_TEST_IP}:${KAFKA_EXTERNAL_PORT:-9094}"
 elif docker ps -a --format '{{.Names}}' | grep -q '^dev-kafka$'; then
   info "重新启动已有容器 dev-kafka..."
   docker start dev-kafka > /dev/null
 else
   info "创建并启动 Kafka 容器（首次拉取镜像可能较慢）..."
   KAFKA_CLUSTER_ID="MkU3OEVBNTcwNTJENDM2Qk"
+  KAFKA_EXTERNAL_PORT="${KAFKA_EXTERNAL_PORT:-9094}"
 
   # bitnamilegacy/kafka 容器内以 uid=1001 运行，宿主目录需提前授权
   mkdir -p "${DATA_DIR}/kafka"
   chown -R 1001:1001 "${DATA_DIR}/kafka" 2>/dev/null || \
     chmod -R 777 "${DATA_DIR}/kafka"   # 无 chown 权限时退回 777
 
+  # 双 listener：INTERNAL 供本机服务（与 kafka.yml 127.0.0.1 一致）；EXTERNAL 供公网 bootstrap（advertise DEPLOY_TEST_IP）
   docker run -d \
     --name dev-kafka \
     --restart unless-stopped \
     -p "${KAFKA_PORT}:9092" \
+    -p "${KAFKA_EXTERNAL_PORT}:9094" \
     -v "${DATA_DIR}/kafka:/bitnami/kafka" \
     -e KAFKA_CFG_NODE_ID=0 \
     -e KAFKA_CFG_PROCESS_ROLES=controller,broker \
-    -e KAFKA_CFG_LISTENERS="PLAINTEXT://:9092,CONTROLLER://:9093" \
-    -e KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP="CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT" \
+    -e KAFKA_CFG_LISTENERS="INTERNAL://:9092,EXTERNAL://:9094,CONTROLLER://:9093" \
+    -e KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP="CONTROLLER:PLAINTEXT,INTERNAL:PLAINTEXT,EXTERNAL:PLAINTEXT" \
     -e KAFKA_CFG_CONTROLLER_QUORUM_VOTERS="0@localhost:9093" \
     -e KAFKA_CFG_CONTROLLER_LISTENER_NAMES=CONTROLLER \
-    -e KAFKA_CFG_ADVERTISED_LISTENERS="PLAINTEXT://127.0.0.1:${KAFKA_PORT}" \
+    -e KAFKA_CFG_INTER_BROKER_LISTENER_NAME=INTERNAL \
+    -e KAFKA_CFG_ADVERTISED_LISTENERS="INTERNAL://127.0.0.1:${KAFKA_PORT},EXTERNAL://${DEPLOY_TEST_IP}:${KAFKA_EXTERNAL_PORT}" \
     -e KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE=true \
     -e KAFKA_KRAFT_CLUSTER_ID="$KAFKA_CLUSTER_ID" \
     "${LOG_OPTS[@]}" \
     bitnamilegacy/kafka:3.5.1 \
     > /dev/null
+  info "  本机 bootstrap: 127.0.0.1:${KAFKA_PORT}（INTERNAL）"
+  info "  外网 bootstrap: ${DEPLOY_TEST_IP}:${KAFKA_EXTERNAL_PORT}（EXTERNAL，PLAINTEXT；请在安全组放行 TCP ${KAFKA_EXTERNAL_PORT}）"
 fi
 start_docker_logger "dev-kafka"
 
@@ -115,7 +121,7 @@ for _i in $(seq 1 45); do
 done
 echo ""  # 清除 \r 留下的行
 if [[ $_kafka_ready -eq 1 ]]; then
-  success "Kafka 已就绪 :${KAFKA_PORT}"
+  success "Kafka 已就绪 本机 127.0.0.1:${KAFKA_PORT}  外网 ${DEPLOY_TEST_IP}:${KAFKA_EXTERNAL_PORT:-9094}"
 else
   error "Kafka 90s 内未就绪，请检查日志: ./deploy-test/logs.sh kafka"
   exit 1
@@ -250,6 +256,7 @@ echo "  Docker 容器日志: $DOCKER_LOG_DIR/"
 echo "  本脚本执行日志: $_CURRENT_SCRIPT_LOG"
 echo ""
 echo -e "  LiveKit 公网: ${LIVEKIT_NODE_IP}:50000-51000/udp (WebRTC 媒体流)"
+echo -e "  Kafka 外网 bootstrap（若已映射）: ${DEPLOY_TEST_IP}:${KAFKA_EXTERNAL_PORT:-9094}  TCP PLAINTEXT"
 echo ""
 success "Docker 基础设施已就绪！"
 echo ""