lib/fluent/plugin/out_kafka_buffered.rb in fluent-plugin-kafka-enchanced-0.5.28 vs lib/fluent/plugin/out_kafka_buffered.rb in fluent-plugin-kafka-enchanced-0.5.29

@@ -214,10 +214,10 @@
             "fields": fields
         }.to_json
         schema = Avro::Schema.parse(schema_json)
 
         avro = AvroTurf::Messaging.new(registry_url: @schema_registry)
-        avro.encode(record.map{|key, value| [key, value.to_s]}.to_h, schema: schema, subject: "#{schema_name}-value")
+        avro.encode(record, schema: schema, subject: "#{schema_name}-value")
       end
     elsif @output_data_type =~ /^attr:(.*)$/
       @custom_attributes = $1.split(',').map(&:strip).reject(&:empty?)
       @custom_attributes.unshift('time') if @output_include_time
       @custom_attributes.unshift('tag') if @output_include_tag