what is the recommended way to ship from fluentd to logstash? We need to run some post processing in a central location after logs are shipped by fluentd from remote servers.
I've tried using out_forward plugin on the fluentd side, and tcp input on the logstash side, using fluent codec. Based on the below:
It doesn't seem to work:
fluent/output.rb:381:rescue in try_flush: temporarily failed to flush the buffer. next_retry=2017-01-08 16:26:10 +0000 error_class="RuntimeError" error="no nodes are available" plugin_id="forward_output"