MongoDBKafkaSinkConnector-postprocessorpost.processor.chainclassnotloading

检查配置中定义的 postprocessor.post.processor.chain 类是否正确加载并在类路径中。也可以在运行时通过使用--plugin-path选项将jar包路径添加到CLASSPATH，以便正确加载类。示例代码如下所示：

{
    "name": "mongo-sink",
    "config": {
        "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
        "topics": "myTopic",
        "connection.uri": "mongodb://localhost:27017",
        "database": "mydb",
        "collection": "myColl",
        "postprocessor.chain": "com.example.MyPostProcessorChain",
        "transforms": "unwrap",
        "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
        "transforms.unwrap.drop.tombstones": "false",
        "transforms.unwrap.delete.handling.mode": "drop",
        "value.converter": "org.apache.kafka.connect.json.JsonConverter",
        "value.converter.schemas.enable": "false",
        "tasks.max": "1"
    },
    "tasks": [
        {
            "connector": "mongo-sink",
            "task": 0
        }
    ]
}