mirrors/pikasTech-unidesk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: restore HWLAB Kafka runtime env rendering

Browse Source
This commit is contained in:
Codex
2026-07-16 23:02:18 +02:00
parent 0bd16f5b42
commit 30cd8ded85
5 changed files with 103 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
scripts/native/hwlab/runtime-gitops-postprocess.mjs
+5
View File
@@ -95,6 +95,11 @@ function patchCloudApiKafkaEnv(container, kafka) {
let changed = false;
changed = setEnvValue(container, "HWLAB_KAFKA_ENABLED", String(kafka.enabled)) || changed;
changed = setEnvValue(container, "HWLAB_KAFKA_AGENTRUN_EVENT_CONSUME_ENABLED", String(kafka.enabled && (kafka.features.directPublish || kafka.features.transactionalProjector))) || changed;
changed = setEnvValue(container, "HWLAB_KAFKA_BOOTSTRAP_SERVERS", String(kafka.bootstrapServers)) || changed;
changed = setEnvValue(container, "HWLAB_KAFKA_STDIO_TOPIC", String(kafka.stdioTopic)) || changed;
changed = setEnvValue(container, "HWLAB_KAFKA_AGENTRUN_EVENT_TOPIC", String(kafka.agentRunEventTopic)) || changed;
changed = setEnvValue(container, "HWLAB_KAFKA_EVENT_TOPIC", String(kafka.hwlabEventTopic)) || changed;
changed = setEnvValue(container, "HWLAB_KAFKA_CLIENT_ID", String(kafka.clientId)) || changed;
changed = setEnvValue(container, "HWLAB_KAFKA_DIRECT_PUBLISH_ENABLED", String(kafka.enabled && kafka.features.directPublish)) || changed;
changed = setEnvValue(container, "HWLAB_WORKBENCH_LIVE_KAFKA_SSE_ENABLED", String(kafka.enabled && kafka.features.liveKafkaSse)) || changed;
const refreshReplayEnabled = kafka.enabled && kafka.features.kafkaRefreshReplay;