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