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'