Kafka(input) + logstash-1.5.1 + elasticsearch 1.5(output) action update?