Details
-
Bug
-
Resolution: Works as Designed
-
Major - P3
-
None
-
1.6.1
-
None
Description
I got an error when I execute this command, can anyone help me?
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" |
}
|
}'
|