Merge pull request #1226 from pikasTech/fix/2243-kafka-topic-separator
fix: separate kafka topic and user manifests
This commit is contained in:
@@ -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")
|
||||
|
||||
Reference in New Issue
Block a user