Hello,
I am using logstash 2.3.2.
Is there anyway to specify in the config file or organize the avsc files in order to use nested Avro with logstash?
This is my config file.
input {
kafka {
codec => avro{
schema_uri => "InstrumentDef.avsc"
}
topic_id => "instrument-def"
reset_beginning => true
auto_offset_reset => "smallest"
zk_connect => "10.10.100.242:2181/kafka"
}
}
output {
stdout {
codec => rubydebug
}
}
and this is the avsc file.
{
"name": "InstrumentDef",
"type": "record",
"fields": [
{
"name": "key",
"type": "InstrKey"
}
]
}
and in the same folder there is an InstrKey.avsc
This works in other languages with more developed avro support, like Java and Scala, but it fails with
" InstrKey is not a schema we know about " in logstash.