kafka-connect-mongodb
kafka-connect-mongodb copied to clipboard
Error: `operationType` field is doc is missing
Source connector configuration
curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" localhost:8083/connectors/ -d ' { "name": "announcer-connector",
"config": { "connector.class": "io.debezium.connector.mongodb.MongoDbConnector",
"mongodb.members.auto.discover": "true",
"mongodb.hosts": "10.60.11.66:27017",
"mongodb.name": "announcer",
"mongodb.user": "***",
"mongodb.password": "***",
"mongodb.ssl.enabled": "false",
"database.include.list": "announcer",
"snapshot.mode": "initial"}
}'
Sink connector configuration
curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" \
localhost:8083/connectors/ -d '{"name":"logs-sink-connector","config":{"connector.class":"com.mongodb.kafka.connect.MongoSinkConnector","tasks.max":"1","topics":"announcer.announcer.logs","change.data.capture.handler":"com.mongodb.kafka.connect.sink.cdc.mongodb.ChangeStreamHandler","connection.uri":"mongodb://10.60.11.70:27017","database":"announcer","collection":"logs","transforms":"unwrap","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","transforms.unwrap.drop.tombstones":false,"transforms.unwrap.delete.handling.mode":"drop","transforms.unwrap.operation.header":true}}'
Caused by: org.apache.kafka.connect.errors.DataException: Error:
operationType field is doc is missing.