How to use value.schema in Kafka connet

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}"
  }
}

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.