I am using this configuration
input{
mongodb{
uri=>"mongodb://localhost:27017/ebyat"
placeholder_db_dir => "/opt/logstash-mongodb/"
placeholder_db_name => "logstash_sqlite.db"
collection => "amenities"
batch_size => 5000
dig_fields => ["property_ids"]
}
}
filter{
mutate{
remove_field=>["_id"]
}
}
output{
stdout{
codec => rubydebug{
metadata => true
}
}
elasticsearch{
action => "update"
index => "ebyat_amenities"
hosts => ["localhost:9200"]
document_id => "%{amenity}"
}
}
Can anyone say what i am doing wrong?
Thanks In Advance