From ec49e60c2f006ad85749b4d26034b3f7412d16da Mon Sep 17 00:00:00 2001 From: Codex Date: Sun, 28 Jun 2026 09:34:25 +0000 Subject: [PATCH] fix: separate kafka topic and user manifests --- scripts/src/platform-infra-kafka.ts | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/scripts/src/platform-infra-kafka.ts b/scripts/src/platform-infra-kafka.ts index dd3f2c05..0d1c1891 100644 --- a/scripts/src/platform-infra-kafka.ts +++ b/scripts/src/platform-infra-kafka.ts @@ -497,7 +497,7 @@ ${listeners} topicOperator: {} userOperator: {} --- -${topicDocs}${userDocs}`; +${topicDocs}---\n${userDocs}`; } function kafkaTopicManifest(kafka: PlatformKafkaConfig, target: KafkaTarget, topic: KafkaTopicSpec): string { @@ -817,6 +817,12 @@ operator = deployment_ready(load("operator") or {}) kafka_obj = load("kafka") or {} topics = [topic_summary(item) for item in items("topics")] users = [user_summary(item) for item in items("users")] +for name in expected_topics: + if not any(item["topicName"] == name for item in topics): + topics.append({"resource": "missing", "topicName": name, "ready": False}) +for name in expected_clients: + if not any(item["name"] == name for item in users): + users.append({"name": name, "ready": False, "secret": None}) topic_ready = all(any(item["topicName"] == name and item["ready"] for item in topics) for name in expected_topics) user_ready = all(any(item["name"] == name and item["ready"] for item in users) for name in expected_clients) secrets = items("secrets")