lib/fluent/plugin/out_kafka_buffered.rb in fluent-plugin-kafka-enchanced-0.5.33 vs lib/fluent/plugin/out_kafka_buffered.rb in fluent-plugin-kafka-enchanced-0.5.34

@@ -246,10 +246,10 @@
         record['enchilada_timestamp'] = timestamp.strftime('%s%3N').to_i
         record = record.map do |key, val|
           [key, (stored_schema['field_types'][key] != 'string' || val.nil? ? val : val.to_s)]
         end.to_h
 
-        avro.encode(record, stored_schema['schema_id'], schema: stored_schema['schema_json'])
+        avro.encode(record, stored_schema['schema_id'], schema: stored_schema['schema'])
       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