Hi, my pipeline is
here is my config used to get input from 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.