lib/fluent/plugin/out_kafka.rb in fluent-plugin-kafka-enchanced-0.5.31 vs lib/fluent/plugin/out_kafka.rb in fluent-plugin-kafka-enchanced-0.5.32

@@ -178,10 +178,10 @@
           registry = avro.instance_variable_get('@registry')
           schema = Avro::Schema.parse(schema_json)
           schema_id = registry.register("#{schema_name}-value", schema)
 
           stored_schema = {
-              'schema' => schema,
+              'schema_json' => schema_json,
               'schema_id' => schema_id,
               'field_types' => field_types
           }
 
           set_schema_to_redis(schema_name, stored_schema)