From 248ccf57349a12194691546f9033f1a332c934bf Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=AD=99=E5=B0=8F=E4=BA=91?= <sunpengchina85@gmail.com>
Date: Fri, 30 May 2025 10:40:00 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E9=85=8D=E7=BD=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 environment.sh  | 5 ++++-
 init/6.kafka.sh | 6 +++---
 2 files changed, 7 insertions(+), 4 deletions(-)

diff --git a/environment.sh b/environment.sh
index 98ae6cb..38e7618 100644
--- a/environment.sh
+++ b/environment.sh
@@ -67,6 +67,7 @@ export SRS_DOMAIN_FULL=${SRS_DOMAIN}:${NGINX_HTTPS_PORT}
 export HHZ_DOMAIN=hhz-${DOMAIN}.${DOMAIN_END}
 export DSP_DOMAIN=dsp-${DOMAIN}.${DOMAIN_END}
 export REGISTRY_HOST=${REGISTRY}/tuoheng/
+export KAFKA_DOMAIN=kafka-${DOMAIN}.${DOMAIN_END}
 
 
 #Nginx 配置
@@ -123,7 +124,7 @@ export MQTT_MEMORY=512m
 #Kafka 配置
 # Kafka对外爆露端口
 if [ -z "$KAFKA_PORT" ]; then
-   export KAFKA_PORT=9092
+   export KAFKA_PORT=9292
 else
     echo "环境变量 KAFKA_PORT 已设置，设置为 ${KAFKA_PORT}"
 fi
@@ -140,6 +141,8 @@ fi
 export KAFKA_NAME=KAFKA_${DOMAIN}
 export KAFKA_MEMORY=1g   
 export KAFKA_DATA=${NETWORK}_kafka_data  
+export KAFKA_DOMAIN_FULL=${KAFKA_DOMAIN}:${KAFKA_PORT}
+ 
 
 #SRS 配置
 # SRS对外爆露端口 Name比较特别,没有DOAMIN后缀
diff --git a/init/6.kafka.sh b/init/6.kafka.sh
index 7a343b5..9b71249 100755
--- a/init/6.kafka.sh
+++ b/init/6.kafka.sh
@@ -36,11 +36,11 @@ fi
 docker run -d \
 --name ${KAFKA_NAME} \
 --network $NETWORK \
--p ${KAFKA_PORT}:9092 \
+-p ${KAFKA_PORT}:${KAFKA_PORT} \
 -e KAFKA_CFG_NODE_ID=1 \
 -e KAFKA_CFG_PROCESS_ROLES=broker,controller \
--e KAFKA_CFG_LISTENERS=PLAINTEXT://:9092,CONTROLLER://:29093 \
--e KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://${KAFKA_NAME}:9092 \
+-e KAFKA_CFG_LISTENERS=PLAINTEXT://:${KAFKA_PORT},CONTROLLER://:29093 \
+-e KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://${KAFKA_DOMAIN_FULL} \
 -e KAFKA_CFG_CONTROLLER_QUORUM_VOTERS=1@${KAFKA_NAME}:29093 \
 -e KAFKA_CFG_CONTROLLER_LISTENER_NAMES=CONTROLLER \
 -e KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT \