How to take input from kafka avro consumer

Elastic Stack Logstash
1

Hi

Currently I have defined kafka as input in logstash but I want to take input from kafka avro consumer (avro-console-consumer) .

Below is my current config
input {
kafka {
bootstrap_servers => "kafka:9092"
topics => ["ecomdb.cscart_db.cscart_orders"]
codec => plain { charset=>"UTF-8" }
}
stdin {
codec => plain { charset => "UTF-8"}
}
}

Thanks,
Saurabh

2

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