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

@@ -160,10 +160,10 @@
             "name": schema_name,
             "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 == 'ltsv'
       require 'ltsv'
       Proc.new { |tag, time, record| LTSV.dump(record) }
     elsif @output_data_type == 'msgpack'