Hi,
I have the corresponding config file :
input {
elasticsearch {
hosts => "localhost"
index => "articles"
add_field => { "[@metadata][kafka_topics]" => ["test1", "test2"] }
}
}
output {
stdout { codec => rubydebug{
metadata => true
} }
kafka {
topic_ids => "%{[@metadata][kafka_topics]}"
}
}
I have changed the output plugin for kafka so now it is supporting arrays .
topic_ids => ["test1","test2"] works smoothly.
but when I try to access the value of the variable it is treated as a string no matter what I try.