Hello sa_N_A,
If I understand correctly, you want to replace the document if the _id already exists. You may not (can’t tell from the details) insert a new document if the _id does not exist.
I would recommend you look into the write strategies that are possible with the connector located here: https://www.mongodb.com/docs/kafka-connector/current/sink-connector/configuration-properties/write-strategies/