lib/fluent/plugin/in_kafka.rb in fluent-plugin-kafka-0.0.6 vs lib/fluent/plugin/in_kafka.rb in fluent-plugin-kafka-0.0.7

@@ -29,10 +29,12 @@
     case @format
     when 'json'
       require 'yajl'
     when 'ltsv'
       require 'ltsv'
+    when 'msgpack'
+      require 'msgpack'
     end
   end
 
   def start
     @loop = Coolio::Loop.new
@@ -108,9 +110,11 @@
       case @format
       when 'json'
         parsed_record = Yajl::Parser.parse(record)
       when 'ltsv'
         parsed_record = LTSV.parse(record)
+      when 'msgpack'
+        parsed_record = MessagePack.unpack(record)
       when 'text'
         parsed_record = record
       end
       parsed_record
     end