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 087ed7755..3d0d03020 100644
--- a/salt/logstash/pipelines/config/so/0800_input_kafka.conf.jinja
+++ b/salt/logstash/pipelines/config/so/0800_input_kafka.conf.jinja
@@ -13,6 +13,7 @@ input {
         codec => json
         topics => ['default-topic', 'kratos-topic', 'soc-topic', 'strelka-topic', 'suricata-topic', 'zeek-topic', 'rita-topic', 'opencanary-topic', 'syslog-topic']
         group_id => 'searchnodes'
+        consumer_threads => 3
         client_id => '{{ GLOBALS.hostname }}'
         security_protocol => 'SSL'
         bootstrap_servers => '{{ bootstrap_servers }}'