From 8080e054444ad4d42647d8d414b4be4ae4e3f3bd Mon Sep 17 00:00:00 2001
From: reyesj2 <94730068+reyesj2@users.noreply.github.com>
Date: Fri, 14 Jun 2024 14:17:26 -0400
Subject: [PATCH] on fresh install kafka nodes pillar may not have populated.
 Avoiding this by only generating kafka input pipeline when kafka nodes pillar
 is not empty

Signed-off-by: reyesj2 <94730068+reyesj2@users.noreply.github.com>
---
 .../config/so/0800_input_kafka.conf.jinja      | 18 ++++++++++--------
 1 file changed, 10 insertions(+), 8 deletions(-)

diff --git a/salt/logstash/pipelines/config/so/0800_input_kafka.conf.jinja b/salt/logstash/pipelines/config/so/0800_input_kafka.conf.jinja
index 9e80456f2..33a4d39e4 100644
--- a/salt/logstash/pipelines/config/so/0800_input_kafka.conf.jinja
+++ b/salt/logstash/pipelines/config/so/0800_input_kafka.conf.jinja
@@ -1,13 +1,14 @@
 {%- set kafka_password = salt['pillar.get']('kafka:password') %}
-{%- set kafka_brokers = salt['pillar.get']('kafka:nodes', {}) %}
+{%- set kafka_brokers = salt['pillar.get']('kafka:nodes', default=None) %}
 {%- set brokers = [] %}
 
-{%- for key, values in kafka_brokers.items() %}
-{%-   if 'broker' in values['role'] %}
-{%-     do brokers.append(key ~ ':9092') %}
-{%-   endif %}
-{%- endfor %}
-{%- set bootstrap_servers = ','.join(brokers) %}
+{%- if kafka_brokers != none %}
+{%-   for key, values in kafka_brokers.items() %}
+{%-     if 'broker' in values['role'] %}
+{%-       do brokers.append(key ~ ':9092') %}
+{%-     endif %}
+{%-   endfor %}
+{%-   set bootstrap_servers = ','.join(brokers) %}
 
 input {
     kafka {
@@ -33,4 +34,5 @@ filter {
       rename => { "@metadata" => "metadata" }
     }
   }
-}
\ No newline at end of file
+}
+{% endif %}
\ No newline at end of file