RetryStreamError privides a stream to be put back in the pipeline for cases where a bulk request failed (e.g some records succeed while others failed)
# File lib/fluent/plugin/out_elasticsearch.rb, line 29 def initialize(retry_stream) @retry_stream = retry_stream end