diff --git a/lib/fluent/plugin/parser_none.rb b/lib/fluent/plugin/parser_none.rb index 8d9bf60457..b3cbbd8647 100644 --- a/lib/fluent/plugin/parser_none.rb +++ b/lib/fluent/plugin/parser_none.rb @@ -27,8 +27,7 @@ class NoneParser < Parser config_param :message_key, :string, default: 'message' def parse(text) - record = {} - record[@message_key] = text + record = {@message_key => text} time = @estimate_current_event ? Fluent::EventTime.now : nil yield time, record end