修改配置

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后缀

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 \