Update or Delete not working with MongodbSink connector… Can you please help… com.mongodb.kafka.connect.MongoSinkConnector.
Iam using below source connector and sink connector…
Source connector:
{
“name”: “inventory-connector”,
“config”: {
“connector.class” : “io.debezium.connector.mongodb.MongoDbConnector”,
“errors.tolerance”: “all”,
“errors.log.enable”: “true”,
“tasks.max” : “1”,
“topic.prefix” : “dbserver1”,
“mongodb.hosts” : “rs0/mongodb:27017”,
“mongodb.user” : “debezium”,
“mongodb.password” : “dbz”,
“database.include.list”: “inventory”,
“database.history.kafka.bootstrap.servers”: “kafka:29092”,
“database.history.kafka.topic”: “schema-changes.inventory”,
“collection.include.list”:“inventory.customers”,
“key.converter.schemas.enable”: false,
“value.converter.schemas.enable”: false,
“key.converter”: “org.apache.kafka.connect.json.JsonConverter”,
“value.converter”: “org.apache.kafka.connect.json.JsonConverter”,
“tombstones.on.delete”: “false”,
“transforms”: “route”,
“transforms.route.type” : “org.apache.kafka.connect.transforms.RegexRouter”,
“transforms.route.regex” : “([^.]+)\.([^.]+)\.([^.]+)”,
“transforms.route.replacement” : “$3”
}
}
Sink connector:
{
“name”: “mongodb-sink”,
“config”: {
“connection.uri”: “mongodb+srv:///?retryWrites=true&w=majority”,
“connector.class” : “com.mongodb.kafka.connect.MongoSinkConnector”,
“errors.tolerance”: “all”,
“errors.log.enable”: “true”,
“tasks.max”: “1”,
“key.ignore”: “true”,
“database”:“iradev”,
“collection”:“customers_copy”,
“topics”:“customers”,
“key.converter”: “org.apache.kafka.connect.storage.StringConverter”,
“value.converter”: “org.apache.kafka.connect.json.JsonConverter”,
“value.converter.schemas.enable”: false,
“change.data.capture.handler”: “com.mongodb.kafka.connect.sink.cdc.debezium.mongodb.MongoDbHandler”,
“mongo.errors.tolerance”: “all”,
“mongo.errors.log.enable”: “true”,
“insert.mode”: “insert”,
“auto.create”: “true”,
“auto.evolve”: “true”
}
}
any missing config for MongodbSinkConnector to take the update/delete transactions