use the following config and you are sorted
{
“name”: “mongo-simple-source”,
“config”: {
“connector.class”: “com.mongodb.kafka.connect.MongoSourceConnector”,
“connection.uri”: “mongodb://mongo1”,
“database”: “test_db”,
“value.converter.schemas.enable”: “false”,
“output.format.value”: “schema”,
“poll.max.batch.size”: “2000”,
“key.converter.schemas.enable”: “false”,
“value.converter”: “org.apache.kafka.connect.json.JsonConverter”,
“change.stream.full.document”: “updateLookup”,
“producer.override.linger.ms”: “50”,
“output.format.key”: “json”,
“output.schema.infer.value”: “true”,
“output.json.formatter”: “com.mongodb.kafka.connect.source.json.formatter.SimplifiedJson”,
“key.converter”: “org.apache.kafka.connect.storage.StringConverter”,
“collection”: “order”,
“topic.namespace.map”: “{"test_db.package":"order-cdc.info"}”,
“name”: “mongo-simple-source”
}
}