Custom adaptation of elasticsearch_river plugin for Logstash