lib/fluent/plugin/out_kafka2.rb in fluent-plugin-kafka-0.7.3 vs lib/fluent/plugin/out_kafka2.rb in fluent-plugin-kafka-0.7.4

@@ -6,10 +6,10 @@
 
 module Fluent::Plugin
   class Fluent::Kafka2Output < Output
     Fluent::Plugin.register_output('kafka2', self)
 
-    helpers :inject, :formatter
+    helpers :inject, :formatter, :event_emitter
 
     config_param :brokers, :array, :value_type => :string, :default => ['localhost:9092'],
                  :desc => <<-DESC
 Set brokers directly:
 <broker1_host>:<broker1_port>,<broker2_host>:<broker2_port>,..