CSEC_PUBLIC/securityonion
1
0
Fork 0
mirror of https://github.com/Security-Onion-Solutions/securityonion.git synced 2025-12-06 09:12:45 +01:00
Code Issues Packages Projects Releases Wiki Activity

kafka logstash input plugin handle empty brokers list

Browse Source 
Signed-off-by: reyesj2 <94730068+reyesj2@users.noreply.github.com>
This commit is contained in:
reyesj2
2024-06-14 23:03:36 -04:00
parent 4e50dabc56
commit 0b1175b46c
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
salt/logstash/pipelines/config/so/0800_input_kafka.conf.jinja
View File

@@ -1,8 +1,8 @@
{%- set kafka_password = salt['pillar.get']('kafka:password') %} {%- 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 = [] %} {%- set brokers = [] %}
{%- if kafka_brokers != none %} {%- if kafka_brokers %}
{%- for key, values in kafka_brokers.items() %} {%- for key, values in kafka_brokers.items() %}
{%- if 'broker' in values['role'] %} {%- if 'broker' in values['role'] %}
{%- do brokers.append(key ~ ':9092') %} {%- do brokers.append(key ~ ':9092') %}