chore: expose history dlq in launchctl

deploy/local/launchctl/README.md

@@ -34,6 +34,7 @@ export VEHICLE_IDENTITY_MYSQL_REFRESH_INTERVAL='60s'
 export MYSQL_JDBC_URL="$VEHICLE_IDENTITY_MYSQL_JDBC_URL"
 export MYSQL_USERNAME="$VEHICLE_IDENTITY_MYSQL_USERNAME"
 export MYSQL_PASSWORD="$VEHICLE_IDENTITY_MYSQL_PASSWORD"
+export KAFKA_TOPIC_HISTORY_DLQ='vehicle.dlq.history.v1'
 export YUTONG_MQTT_ENABLED='false'
 export YUTONG_MQTT_URI=''
 export YUTONG_MQTT_TOPIC='#'

deploy/local/launchctl/com.lingniu.vehicle-history.plist.template

@@ -40,6 +40,8 @@
     <string>vehicle.event.mqtt-yutong.v1</string>
     <key>KAFKA_TOPIC_YUTONG_MQTT_RAW</key>
     <string>vehicle.raw.mqtt-yutong.v1</string>
+    <key>KAFKA_TOPIC_HISTORY_DLQ</key>
+    <string>__KAFKA_TOPIC_HISTORY_DLQ__</string>
     <key>TDENGINE_HISTORY_ENABLED</key>
     <string>true</string>
     <key>TDENGINE_HISTORY_DATABASE</key>

deploy/local/launchctl/render.py

@@ -48,6 +48,7 @@ def replacements() -> dict[str, str]:
         "__MYSQL_JDBC_URL__": env("MYSQL_JDBC_URL", identity_jdbc),
         "__MYSQL_USERNAME__": env("MYSQL_USERNAME", identity_username),
         "__MYSQL_PASSWORD__": env("MYSQL_PASSWORD", identity_password),
+        "__KAFKA_TOPIC_HISTORY_DLQ__": env("KAFKA_TOPIC_HISTORY_DLQ", "vehicle.dlq.history.v1"),
         "__YUTONG_MQTT_ENABLED__": env("YUTONG_MQTT_ENABLED", "false"),
         "__YUTONG_MQTT_URI__": env("YUTONG_MQTT_URI", ""),
         "__YUTONG_MQTT_TOPIC__": env("YUTONG_MQTT_TOPIC", "#"),