mongodb - MongoDB Sink Connector を使用して、別の主キーで既存のドキュメントを更新する

Question

pgsql と MongoDB の間でデータの同期を維持する Confluent Cloud 経由で MongoDB Sink Connector をセットアップしようとしています。

id以下の構成が(int) フィールド (_id - objectId ではない)に基づいて既存のドキュメントを更新することを期待していますが、消費時に MongoDB に新しいドキュメントを作成するだけです。pg からのドキュメントには _id フィールドが含まれないため、pgsql の主キー (id) でルックアップを行う必要があります。

これが期待どおりに機能しない理由はありますか?

 {
  "connector.class": "MongoDbAtlasSink",
  "name": "mongodb-sink",
  "kafka.api.key": "mykey",
  "kafka.api.secret": "mysecret",
  "input.data.format": "JSON",
  "topics":"mytopic",
  "connection.host": "myhost",
  "connection.user": "myuser",
  "connection.password": "mypassword",
  "database": "mydatabase",
  "delete.on.null.values": "false",
  "tasks.max": "1",
  "document.id.strategy": "com.mongodb.kafka.connect.sink.processor.id.strategy.PartialValueStrategy",
  "document.id.strategy.partial.value.projection.list":"id",
  "document.id.strategy.partial.value.projection.type":"AllowList",
"writemodel.strategy":"com.mongodb.kafka.connect.sink.writemodel.strategy.ReplaceOneBusinessKeyStrategy"
}