logstash_htt_config.rb

input {
  http {
	port => "8081"
	codec => "json"
  }
}

filter {

}

output {
          if "_grokparsefailure" in [tags] {
            elasticsearch { hosts => ["172.16.0.7:9200"] 
            index => "logstash-http-input-test-%{+YYYY.MM}"
            }
          }
          else {
            elasticsearch { hosts => ["172.16.0.7:9200"] 
            index => "logstash-http-input-test-%{+YYYY.MM}"
            }
          }
}