lib/fluent/plugin/out_kafka.rb in fluent-plugin-kafka-enchanced-0.5.3 vs lib/fluent/plugin/out_kafka.rb in fluent-plugin-kafka-enchanced-0.5.4

@@ -65,9 +65,11 @@
 
   def initialize
     super
 
     require 'kafka'
+    require "avro_turf"
+    require "avro-builder"
 
     @kafka = nil
   end
 
   def refresh_client