HI there:
We are now trying to provide the value schema and register the schema into schema registry. But when we set both value convert, schema registry url and value.schema. The schema not show in schema-registry. It is possible to do that? Or we are trying to use SMT to do that. Thanks a lot
The source connector is below
{
"name": "cdc-demo-debezium-db2-source-001",
"config": {
"connector.class": "com.github.jcustenborder.kafka.connect.spooldir.SpoolDirSchemaLessJsonSourceConnector",
"tasks.max": "1",
"topic": "provided_avro_2",
"flush.size": "1",
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
"value.converter":"io.confluent.connect.avro.AvroConverter",
"value.converter.schema.registry.url":"http://schema-registry:8081",
"confluent.topic.bootstrap.servers": "broker:29092",
"confluent.topic.replication.factor": "1",
"input.path":"/data/shared/safe/input",
"input.file.pattern": "input.json",
"halt.on.error":"false",
"error.path": "/data/shared/safe/error",
"finished.path": "/data/shared/safe/finished",
"value.schema":"{\n \"name\": \"MyClass\",\n \"type\": \"record\",\n \"namespace\": \"com.acme.avro\",\n \"fields\": [\n {\n \"name\": \"id\",\n \"type\": \"string\"\n },\n {\n \"name\": \"batters\",\n \"type\": \"string\"\n }\n ]\n}"
}
}