In our last blog post, we introduced a reference implementation for capturing change data capture (CDC) events from a MongoDB database using Debezium Server and Memphis.dev. At the end of the post, we noted that MongoDB records are serialized as strings in Debezium CDC messages like so:
Python
{
“schema” : …,
“payload” : {
“before” : null,
“after” : “{\”_id\”: {\”$oid\”: \”645fe9eaf4790c34c8fcc2ed\”},\”creation_timestamp\”: {\”$date\”: 1684007402978},\”due_date\”: {\”$date\”: 1684266602978},\”description\”: \”buy milk\”,\”completed\”: false}”,
…
}
}
“schema” : …,
“payload” : {
“before” : null,
“after” : “{\”_id\”: {\”$oid\”: \”645fe9eaf4790c34c8fcc2ed\”},\”creation_timestamp\”: {\”$date\”: 1684007402978},\”due_date\”: {\”$date\”: 1684266602978},\”description\”: \”buy milk\”,\”completed\”: false}”,
…
}
}