diff --git a/lib/fluent/plugin/in_s3.rb b/lib/fluent/plugin/in_s3.rb index 43c001b..4ebe989 100644 --- a/lib/fluent/plugin/in_s3.rb +++ b/lib/fluent/plugin/in_s3.rb @@ -213,7 +213,7 @@ def run begin @poller.poll(options) do |message| begin - body = JSON.parse(message.body) + body = JSON.parse(message.body, allow_duplicate_key: true) log.debug(body) next unless is_valid_queue(body) # skip test queue if @match_regexp