curl -X POST \
--url http://localhost:8083/connectors \
-H "Content-Type: application/json" \
--data '
{
 "name": "zbcde",
 "config": {
 "connector.class": "com.mongodb.kafka.connect.MongoSourceConnector",
 "connection.uri": "mongodb://localhost:27017/?authSource=admin",
 "database": "test",
 "collection": "test_kafka",
 "copy.existing" :"true",
 "publish.full.document.only":"true",
 "change.stream.full.document":"updateLookup",
 "output.format.key":"schema",
 "output.schema.key":"{\"name\":\"keySchema\",\"type\":\"record\",\"fields\":[{\"name\": \"fullDocument\",\"type\": \"record\",\"fields\":[ { \"name\": \"a\", \"type\": \"string\" },{ \"name\": \"b\", \"type\": \"string\" },{ \"name\": \"c\", \"type\": \"string\" }]}]}",
 "output.json.formatter":"com.mongodb.kafka.connect.source.json.formatter.SimplifiedJson"
 }
}'