From 695058efabc58af8f17937ff14a9dee0b587185e Mon Sep 17 00:00:00 2001
From: zepinos <zepinos@gmail.com>
Date: Fri, 3 Jul 2020 18:39:13 +0900
Subject: [PATCH] fix error

---
 lib/fluent/plugin/parser_msgpack.rb | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/lib/fluent/plugin/parser_msgpack.rb b/lib/fluent/plugin/parser_msgpack.rb
index 6d24490..2baf227 100644
--- a/lib/fluent/plugin/parser_msgpack.rb
+++ b/lib/fluent/plugin/parser_msgpack.rb
@@ -1,10 +1,13 @@
+require 'fluent/parser'
+
 module Fluent
   class TextParser
     class MsgPackParser < Parser
       Plugin.register_parser("msgpack", self)
 
       def parse(text)
-        yield MessagePack.unpack(text)
+        yield Fluent::EventTime.now, MessagePack.unpack(text)
+        # yield nil, MessagePack.unpack(text)
       end
     end
   end