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")