logstash_01 / json

input {
  stdin {}
}

filter {
  json {
    source => "message"
  }
  mutate {
    remove_field => ["path", "@version", "message", "host", "@timestamp"]
  }
}

output {
  stdout {
    codec => rubydebug { }
  }
  elasticsearch {
    hosts => "192.168.240.183:9200"
    index => "kim"
    document_type => "_doc"
  }
}