When trying to send records to a json schema topic, rest proxy always tries to overwrite the defined schema with some default value
{\"$schema\":\"http://json-schema.org/draft-04/schema#\",\"title\":\"Object Node\"}"
The example from the quick start guide does not work if the value schema is set to
"{\"type\":\"object\",\"properties\":{\"name\":{\"type\":\"string\"}}}"
and the compatibility mode to full.
Tracing down the code, I think that the code in
io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializer#serialize
which is called during sending data to the broker, always uses the generic ObjectNode to lookup the schema. The original schema_value is not available in this class.
When trying to send records to a json schema topic, rest proxy always tries to overwrite the defined schema with some default value
{\"$schema\":\"http://json-schema.org/draft-04/schema#\",\"title\":\"Object Node\"}"
The example from the quick start guide does not work if the value schema is set to
"{\"type\":\"object\",\"properties\":{\"name\":{\"type\":\"string\"}}}"
and the compatibility mode to full.Tracing down the code, I think that the code in
io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializer#serialize
which is called during sending data to the broker, always uses the generic ObjectNode to lookup the schema. The original schema_value is not available in this class.