# How to get input to logstash from kafka consumer instead of kafka bootstrap server?

**URL:** <https://discuss.elastic.co/t/how-to-get-input-to-logstash-from-kafka-consumer-instead-of-kafka-bootstrap-server/131253>\
**Category:** Logstash\
**Created:** [May 10, 2018, 6:01am UTC](https://discuss.elastic.co/t/how-to-get-input-to-logstash-from-kafka-consumer-instead-of-kafka-bootstrap-server/131253 "2018-05-10T06:01:50Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![RameshNagargoje](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/rameshnagargoje/32/30212_2.png) [@RameshNagargoje](https://discuss.elastic.co/u/RameshNagargoje)\
**Post date:** [May 10, 2018, 6:01am UTC](https://discuss.elastic.co/t/how-to-get-input-to-logstash-from-kafka-consumer-instead-of-kafka-bootstrap-server/131253/1 "2018-05-10T06:01:50Z")

</div>

Hi, my pipeline is

producer--\>kafka--\>consumer--\>logstash--\>ES--\>Kibana

here is my config used to get input from kafka  
input  
{  
kafka  
{  
codec =\> json  
bootstrap\_servers =\> "10.24.13.13:9092"  
topics =\> ["topic\_dmesg","topic\_syslog"]  
}  
}

Here i am getting input for logstash wahtever producer is sent,  
But i dont want to get it as it is,  
need to aggregate logs using consumer and send after aggregation of logs logstash have to read it from kafka consumer which are aggregated logs.

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [June 7, 2018, 6:01am UTC](https://discuss.elastic.co/t/how-to-get-input-to-logstash-from-kafka-consumer-instead-of-kafka-bootstrap-server/131253/2 "2018-06-07T06:01:56Z")

</div>

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.