Hi Team ,
I have a scenario when Mongo DB sink connector inserts the data it should use different business key & if the same data is found in Kafka topic (When the connector performs update) we should be able to change the business key .
Example : Kafka topic payload : {id:“11”,“pid”:“12”,“sid”:“13”}
Existing connector configuration I have used is :
“document.id.strategy”:“com.mongodb.kafka.connect.sink.processor.id.strategy.PartialValueStrategy”,
“document.id.strategy.partial.value.projection.list”:“id,pid”,
“document.id.strategy.partial.value.projection.type”:“AllowList”,
“writemodel.strategy”:“com.mongodb.kafka.connect.sink.writemodel.strategy.ReplaceOneBusinessKeyStrategy”
when the connector is performing update we should be able to use business keys as
“document.id.strategy.partial.value.projection.list”:“id,pid,sid” .
Is there a way to achieve this by providing dynamic business keys .