I am doing sink from Postgres to MongoDB by MongoSinkConnector with Kafka. (
I can check there is
u(= update) in
op(= operationType) when I consume Kafka messages produced by Postgres from
However, all the operation types from updating Postgres’s records are not
replace in op log of MongoDB.
replace default operation type when updating document by MongoSinkConnector?
If so, Is there any option to change it to