shishengliang/lingniu-vehicle-ingest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

deploy: make yutong mqtt opt-in

Browse Source
This commit is contained in:
lingniu
2026-07-01 03:57:41 +08:00
parent 6ab2f25387
commit 371b89aeb0
2 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
deploy/portainer/docker-compose.yml
View File

@@ -95,7 +95,8 @@ services:
environment: environment:
<<: *common-env <<: *common-env
HTTP_PORT: 20500 HTTP_PORT: 20500
YUTONG_MQTT_ENABLED: ${YUTONG_MQTT_ENABLED:-true} YUTONG_MQTT_ENABLED: ${YUTONG_MQTT_ENABLED:-false}
YUTONG_MQTT_AUTO_STARTUP: ${YUTONG_MQTT_AUTO_STARTUP:-true}
KAFKA_CONSUMER_ENABLED: "false" KAFKA_CONSUMER_ENABLED: "false"
KAFKA_NODE_ID: ${KAFKA_NODE_ID_MQTT:-yutong-mqtt-portainer} KAFKA_NODE_ID: ${KAFKA_NODE_ID_MQTT:-yutong-mqtt-portainer}
VEHICLE_IDENTITY_STORE: ${VEHICLE_IDENTITY_STORE:-mysql} VEHICLE_IDENTITY_STORE: ${VEHICLE_IDENTITY_STORE:-mysql}
@@ -103,7 +104,7 @@ services:
VEHICLE_IDENTITY_MYSQL_USERNAME: ${MYSQL_USERNAME:-} VEHICLE_IDENTITY_MYSQL_USERNAME: ${MYSQL_USERNAME:-}
VEHICLE_IDENTITY_MYSQL_PASSWORD: ${MYSQL_PASSWORD:-} VEHICLE_IDENTITY_MYSQL_PASSWORD: ${MYSQL_PASSWORD:-}
YUTONG_MQTT_ENDPOINT_NAME: ${YUTONG_MQTT_ENDPOINT_NAME:-yutong} YUTONG_MQTT_ENDPOINT_NAME: ${YUTONG_MQTT_ENDPOINT_NAME:-yutong}
YUTONG_MQTT_URI: ${YUTONG_MQTT_URI:-tcp://127.0.0.1:1883} YUTONG_MQTT_URI: ${YUTONG_MQTT_URI:-}
YUTONG_MQTT_TOPIC: "${YUTONG_MQTT_TOPIC:-#}" YUTONG_MQTT_TOPIC: "${YUTONG_MQTT_TOPIC:-#}"
YUTONG_MQTT_QOS: ${YUTONG_MQTT_QOS:-1} YUTONG_MQTT_QOS: ${YUTONG_MQTT_QOS:-1}
YUTONG_MQTT_CLIENT_ID: ${YUTONG_MQTT_CLIENT_ID:-lingniu-yutong-mqtt} YUTONG_MQTT_CLIENT_ID: ${YUTONG_MQTT_CLIENT_ID:-lingniu-yutong-mqtt}

6
modules/apps/yutong-mqtt-app/src/test/java/com/lingniu/ingest/yutongmqttapp/YutongMqttPortainerComposeTest.java
View File

@@ -18,9 +18,11 @@ class YutongMqttPortainerComposeTest {
.contains("KAFKA_TOPIC_YUTONG_MQTT_EVENT:") .contains("KAFKA_TOPIC_YUTONG_MQTT_EVENT:")
.contains("KAFKA_TOPIC_YUTONG_MQTT_RAW:") .contains("KAFKA_TOPIC_YUTONG_MQTT_RAW:")
.contains("KAFKA_TOPIC_YUTONG_MQTT_DLQ:") .contains("KAFKA_TOPIC_YUTONG_MQTT_DLQ:")
.contains("YUTONG_MQTT_ENABLED: ${YUTONG_MQTT_ENABLED:-true}") .contains("YUTONG_MQTT_ENABLED: ${YUTONG_MQTT_ENABLED:-false}")
.contains("YUTONG_MQTT_URI: ${YUTONG_MQTT_URI:-tcp://127.0.0.1:1883}") .contains("YUTONG_MQTT_AUTO_STARTUP: ${YUTONG_MQTT_AUTO_STARTUP:-true}")
.contains("YUTONG_MQTT_URI: ${YUTONG_MQTT_URI:-}")
.contains("YUTONG_MQTT_TOPIC: \"${YUTONG_MQTT_TOPIC:-#}\"") .contains("YUTONG_MQTT_TOPIC: \"${YUTONG_MQTT_TOPIC:-#}\"")
.doesNotContain("YUTONG_MQTT_URI: ${YUTONG_MQTT_URI:-tcp://127.0.0.1:1883}")
.doesNotContain("KAFKA_TOPIC_PARTNER_EVENT") .doesNotContain("KAFKA_TOPIC_PARTNER_EVENT")
.doesNotContain("KAFKA_TOPIC_PARTNER_RAW") .doesNotContain("KAFKA_TOPIC_PARTNER_RAW")
.doesNotContain("KAFKA_TOPIC_PARTNER_DLQ") .doesNotContain("KAFKA_TOPIC_PARTNER_DLQ")