From 65274e89d7c8741fe63536e030483c2e2af21665 Mon Sep 17 00:00:00 2001
From: reyesj2 <94730068+reyesj2@users.noreply.github.com>
Date: Fri, 5 Apr 2024 15:38:00 -0400
Subject: [PATCH] Add client_id to logstash pipeline. To identify which
 searchnode is pulling messages

Signed-off-by: reyesj2 <94730068+reyesj2@users.noreply.github.com>
---
 salt/logstash/pipelines/config/so/0800_input_kafka.conf.jinja | 1 +
 1 file changed, 1 insertion(+)

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 957f7da19..0260b774e 100644
--- a/salt/logstash/pipelines/config/so/0800_input_kafka.conf.jinja
+++ b/salt/logstash/pipelines/config/so/0800_input_kafka.conf.jinja
@@ -19,6 +19,7 @@ input {
         #Can ingest multiple topics. Set to a value from SOC UI?
         topics => ['ea-logs']
         group_id => 'searchnodes'
+        client_id => '{{ GLOBALS.hostname }}'
         security_protocol => 'SSL'
         bootstrap_servers => '{{ bootstrap_servers }}'
         ssl_keystore_location => '/usr/share/logstash/kafka-logstash.p12'