Implement elasticsearch/logstash-forwarder#260