我们可以在 mongodb 中更新/更新记录吗？数据源是kafka

Question

我们可以在 mongodb 中更新/更新记录，但是如果有任何方法或函数可以直接在 mongodb 中更新或更新文档，并且源系统是 kafka，目标是 mongodb。

Answer 1

是的，我们可以更新/更新数据。对于更新，您必须在 Kafka 连接器中定义一个参数。并将要更新记录的基础列列入白名单。属性如下：

document.id.strategy=com.mongodb.kafka.connect.sink.processor.id.strategy.PartialValueStrategy
value.projection.list=tokenNumber
value.projection.type=whitelist
writemodel.strategy=com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneTimestampsStrategy