我正在使用jdbc源和kafka connect mongodb sink连接器将数据从jdbc流式传输到mongodb。
到目前为止，我可以通过以下配置在mongodb端将所有插入和更新作为新文档（是的，更新作为新文档插入）；
repo:httpshttp://github.com/hpgrahsl/kafka-connect-mongodb
配置：

"mongodb.document.id.strategy":"at.grahsl.kafka.connect.mongodb.processor.id.strategy.BsonOidStrategy",
"mongodb.post.processor.chain":"at.grahsl.kafka.connect.mongodb.processor.DocumentIdAdder",
"mongodb.delete.on.null.values":false,
"mongodb.writemodel.strategy":"at.grahsl.kafka.connect.mongodb.writemodel.strategy.ReplaceOneDefaultStrategy"

我现在想要实现的是在oracle端更新行的情况下更新文档。
通过以下配置，我只能将oracle端最后一次插入或更新作为单个文档插入到mongodb集合中。我的意思是，我在mongodb中发现的是一个集合，其中包含一个文档，这是最后一个操作。

"mongodb.document.id.strategy":"at.grahsl.kafka.connect.mongodb.processor.id.strategy.PartialValueStrategy",
"mongodb.key.projection.list": "name,surname",
"mongodb.key.projection.type":"whitelist",
"mongodb.post.processor.chain":"at.grahsl.kafka.connect.mongodb.processor.DocumentIdAdder",
"mongodb.writemodel.strategy":"at.grahsl.kafka.connect.mongodb.writemodel.strategy.ReplaceOneBusinessKeyStrategy"

提前通知任何帮助。非常感谢，索纳