# How to increase the performance of the kafka input in indexer
**URL:** https://discuss.elastic.co/t/how-to-increase-the-performance-of-the-kafka-input-in-indexer/304549
**Category:** Logstash
**Created:** [May 12, 2022, 9:42am UTC](https://discuss.elastic.co/t/how-to-increase-the-performance-of-the-kafka-input-in-indexer/304549 "2022-05-12T09:42:39Z")
**Posts on this page:** 2
**Page:** 1
### Author:  [@Marco\_Bonardo](https://discuss.elastic.co/u/Marco_Bonardo)
#### Post date: [May 12, 2022, 9:42am UTC](https://discuss.elastic.co/t/how-to-increase-the-performance-of-the-kafka-input-in-indexer/304549/1 "2022-05-12T09:42:39Z")
Hello everyone, I have a problem I've been working on for days and I can't find a compatible solution. I need to consume about **150k messages per second** via a kafka input / topic / groupid. I have **8 logstash on separate machines** and performers of both cpu and memory (I already have about fifteen active pipelines but they are not a problem at the moment). Basically I can consume about 8k per second of messages, using the **consumer\_thread value of 5 for each node** (with topic partition 48). I always arrive at a maximum of about **42k messages per second** and the rest goes into lag. I've tried working with the worker and batch.size parameter but they haven't changed the context. I ask if you have tested solutions that can do for me, without increasing other logstash indexers. Thank you all
---
### Author:  [@system](https://discuss.elastic.co/u/system)
#### Post date: [June 9, 2022, 9:43am UTC](https://discuss.elastic.co/t/how-to-increase-the-performance-of-the-kafka-input-in-indexer/304549/2 "2022-06-09T09:43:19Z")
This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.