diff --git a/init/1.network.sh b/init/1.network.sh index ef6771e..f1a65f4 100755 --- a/init/1.network.sh +++ b/init/1.network.sh @@ -1,7 +1,10 @@ source ../environment.sh if ! docker network inspect ${NETWORK} >/dev/null 2>&1; then - docker network create --driver bridge ${NETWORK} - echo "创建 ${NETWORK} bridge 网络成功" + docker network create --driver bridge \ + --subnet=172.20.0.0/16 \ + --gateway=172.20.0.1 \ + ${NETWORK} + echo "创建 ${NETWORK} bridge 网络成功,子网: 172.20.0.0/16,网关: 172.20.0.1" else echo "${NETWORK} 网络已存在" fi \ No newline at end of file diff --git a/init/6.kafka.sh b/init/6.kafka.sh index 7a2af6e..7a343b5 100755 --- a/init/6.kafka.sh +++ b/init/6.kafka.sh @@ -61,4 +61,38 @@ ${KAFKA_IMAGE} docker ps +# 等待 Kafka 服务就绪 +echo "等待 Kafka 服务就绪..." +sleep 30 + +# 创建所需的 topics +echo "开始创建 Kafka topics..." + +# 创建机场相关 topics +docker exec ${KAFKA_NAME} /opt/bitnami/kafka/bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --topic airport-push-voltage-imitateFly +docker exec ${KAFKA_NAME} /opt/bitnami/kafka/bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --topic airport-push-voltage-task +docker exec ${KAFKA_NAME} /opt/bitnami/kafka/bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --topic airport-push-voltage-test +docker exec ${KAFKA_NAME} /opt/bitnami/kafka/bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --topic business-update-dataPermissions-task + +# 创建 DSP 算法相关 topics +docker exec ${KAFKA_NAME} /opt/bitnami/kafka/bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --topic dsp-alg-online-tasks +docker exec ${KAFKA_NAME} /opt/bitnami/kafka/bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --topic dsp-alg-offline-tasks +docker exec ${KAFKA_NAME} /opt/bitnami/kafka/bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --topic dsp-alg-image-tasks +docker exec ${KAFKA_NAME} /opt/bitnami/kafka/bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --topic dsp-alg-task-results +docker exec ${KAFKA_NAME} /opt/bitnami/kafka/bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --topic dsp-local + +# 创建 DSP 录制相关 topics +docker exec ${KAFKA_NAME} /opt/bitnami/kafka/bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --topic dsp-recording-task +docker exec ${KAFKA_NAME} /opt/bitnami/kafka/bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --topic dsp-recording-result +docker exec ${KAFKA_NAME} /opt/bitnami/kafka/bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --topic dsp-recording-local + +# 创建 DSP 推流相关 topics +docker exec ${KAFKA_NAME} /opt/bitnami/kafka/bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --topic dsp-push-stream-task +docker exec ${KAFKA_NAME} /opt/bitnami/kafka/bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --topic dsp-push-stream-result +docker exec ${KAFKA_NAME} /opt/bitnami/kafka/bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --topic dsp-push-stream-local + +# 列出所有创建的 topics +echo "已创建的 topics 列表:" +docker exec ${KAFKA_NAME} /opt/bitnami/kafka/bin/kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --list + \ No newline at end of file