Is there some special trick to getting the couchbase source connector to generate and add the schema for JSON messages? I have the following value settings in the connector property file:
value.converter = org.apache.kafka.connect.json.JsonConverter
Since Couchbase doesn’t know anything about the schema, there’s not much the connector can do on its own. There’s a DefaultSchemaSourceHandler, but its schema is just for document metadata, and the document itself is passed as a blob. One option would be to use it as a template for a custom SourceHandler that defines a schema tailored to your document content.