Hi. I’m using the Debezium source Sql Server and saving to Kafka and I’m using the sink to save the data to mongodb. I would like to know if it is possible to save data only from fields that have been changed. For example, json there are fields before and after comparing those fields and saving only the changes.
Hi Fernando,
At the moment the supported sources for the CDC are :
- MongoDB
- MySql
- PostgreSQL
https://docs.mongodb.com/kafka-connector/master/kafka-sink-cdc/
If you are working with one of the sources above consider using a post processor to compute the changed documents/fields.
Thank you
Pavel