From 0b1175b46c4ccb768ce0294ea0f89d05c53bd6e9 Mon Sep 17 00:00:00 2001
From: reyesj2 <94730068+reyesj2@users.noreply.github.com>
Date: Fri, 14 Jun 2024 23:03:36 -0400
Subject: [PATCH] kafka logstash input plugin handle empty brokers list

Signed-off-by: reyesj2 <94730068+reyesj2@users.noreply.github.com>
---
 salt/logstash/pipelines/config/so/0800_input_kafka.conf.jinja | 4 ++--
 1 file changed, 2 insertions(+), 2 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 33a4d39e4..dfb246210 100644
--- a/salt/logstash/pipelines/config/so/0800_input_kafka.conf.jinja
+++ b/salt/logstash/pipelines/config/so/0800_input_kafka.conf.jinja
@@ -1,8 +1,8 @@
 {%- set kafka_password = salt['pillar.get']('kafka:password') %}
-{%- set kafka_brokers = salt['pillar.get']('kafka:nodes', default=None) %}
+{%- set kafka_brokers = salt['pillar.get']('kafka:nodes', {}) %}
 {%- set brokers = [] %}
 
-{%- if kafka_brokers != none %}
+{%- if kafka_brokers %}
 {%-   for key, values in kafka_brokers.items() %}
 {%-     if 'broker' in values['role'] %}
 {%-       do brokers.append(key ~ ':9092') %}