请按照提供的链接，它有关于Kafka蒙戈连接器的所有信息。我已经成功地实现了upsert功能。您只需要仔细阅读这个文档。
Kafka连接器-mongodb

实际上，这是一个upsert，如果${uniquefieldtoupdateon}不在mongo中，我们希望插入，如果它存在，则更新如下。
以下配置状态：
将${uniquefieldtoupdateon}替换为要对其进行更新建模的记录所特有的字段。
allowlist（白名单）此字段用于 PartialValueStrategy 允许为id策略投影自定义值字段。
replaceonebusinesskeystrategy意味着只更新上面声明的唯一字段引用的一个文档。

"document.id.strategy.partial.value.projection.list":"${uniqueFieldToUpdateOn}",
"document.id.strategy.partial.value.projection.type":"AllowList",
"writemodel.strategy":"com.mongodb.kafka.connect.sink.writemodel.strategy.ReplaceOneBusinessKeyStrategy"