lib/fluent/plugin/in_kafka.rb in fluent-plugin-kafka-0.1.4 vs lib/fluent/plugin/in_kafka.rb in fluent-plugin-kafka-0.1.5

@@ -1,5 +1,6 @@
+require 'fluent/input'
 module Fluent
 
 class KafkaInput < Input
   Plugin.register_input('kafka', self)
 
@@ -81,10 +82,11 @@
       require 'msgpack'
     end
   end
 
   def start
+    super
     @loop = Coolio::Loop.new
     opt = {}
     opt[:max_bytes] = @max_bytes if @max_bytes
     opt[:max_wait_ms] = @max_wait_ms if @max_wait_ms
     opt[:min_bytes] = @min_bytes if @min_bytes
@@ -116,9 +118,10 @@
   end
 
   def shutdown
     @loop.stop
     @zookeeper.close! if @zookeeper
+    super
   end
 
   def run
     @loop.run
   rescue