I'm trying to input avro file and link it to its avsc file and write that into elasticsearch.
This is my config file,
input {
file {
path => "twitter.avro"
type => "avro"
codec => { avro => {
schema_uri => "twitter.avsc"
}
}
}
}
filter {
#Only matched data are send to output.
}
output {
elasticsearch { hosts => ["localhost:9200"] }
stdout{ codec => json }
}
I keep getting this error,
[2017-06-23T13:15:05,644][ERROR][logstash.agent ] Cannot create pipeline {:reason=>"undefined method `execution_context=' for ["avro", {"schema_uri"=>"C:/config/twitter.avsc"}]:Array"}
Kindly help.