diff --git a/lib/fluent/plugin/out_splunk-http-eventcollector.rb b/lib/fluent/plugin/out_splunk-http-eventcollector.rb index d6d54bd..4ec183a 100644 --- a/lib/fluent/plugin/out_splunk-http-eventcollector.rb +++ b/lib/fluent/plugin/out_splunk-http-eventcollector.rb @@ -216,7 +216,7 @@ def write(chunk) split_chunk = chunk.read.split("}{").each do |x| # Reconstruct the opening{/closing} that #split() strips off. x.prepend("{") unless x.start_with?("{") - x << "}" unless x.end_with?("}") + x << "}" unless x.end_with?("}}") end log.debug "Pushing #{numfmt(split_chunk.size)} events (" + "#{numfmt(chunk.read.bytesize)} bytes) to Splunk."