Logstash confluent avro topic read

Elastic Stack Logstash
1

Hi...I create a Java producer using avro in kafka topic....but when I try to read the topic using logstash...its giving empty messages....my confi file is given below...

input {
kafka {
bootstrap_servers => "localhost:9092"
topics => ["madhu"]
codec => avro {
schema_uri => "/usr/share/logstash/bin/Customer.avsc"
}
}
}
output {

stdout {
codec => rubydebug
}
elasticsearch {
hosts => ["localhost:9200"]
codec => json_lines
index => "sammy"
}
}

Any idea...where I am wrong...

Thanks

2

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