From 433309ef1a901591b4b6b1f60009cd25db5d6272 Mon Sep 17 00:00:00 2001
From: reyesj2 <94730068+reyesj2@users.noreply.github.com>
Date: Fri, 5 Apr 2024 09:35:12 -0400
Subject: [PATCH] Generate kafka cluster id if it doesn't exist

Signed-off-by: reyesj2 <94730068+reyesj2@users.noreply.github.com>
---
 salt/kafka/storage.sls | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/salt/kafka/storage.sls b/salt/kafka/storage.sls
index 778c054e2..e99455e3d 100644
--- a/salt/kafka/storage.sls
+++ b/salt/kafka/storage.sls
@@ -6,7 +6,13 @@
 {% from 'allowed_states.map.jinja' import allowed_states %}
 {% if sls.split('.')[0] in allowed_states %}
 {%   from 'vars/globals.map.jinja' import GLOBALS %}
-{% set kafka_cluster_id = salt['pillar.get']('secrets:kafka_cluster_id')%}
+{% set kafka_cluster_id = salt['pillar.get']('secrets:kafka_cluster_id', default=None) %}
+
+{% if kafka_cluster_id is none %}
+generate_kafka_cluster_id:
+  cmd.run:
+    - name: /usr/sbin/so-kafka-clusterid
+{% endif %}
 
 {# Initialize kafka storage if it doesn't already exist. Just looking for meta.properties in /nsm/kafka/data #}
 {% if salt['file.file_exists']('/nsm/kafka/data/meta.properties') %}