Open
Description
According to debezium documetation there a currently two possible kinds of records:
- with schema
{ "schema": {...}, "payload": { "op": "u", "source": { ... }, "ts_ms" : "...", "before" : { "field1" : "oldvalue1", "field2" : "oldvalue2" }, "after" : { "field1" : "newvalue1", "field2" : "newvalue2" } } }
- without schema
{ "op": "u", "source": { ... }, "ts_ms" : "...", "before" : { "field1" : "oldvalue1", "field2" : "oldvalue2" }, "after" : { "field1" : "newvalue1", "field2" : "newvalue2" } }
As you can see it looks very similar to the CDC records in the NEW_AND_OLD_IMAGES
mode and JSON
format.
- Add new CDC format like
DEBEZIUM
. - Add
schema
to the CDC records (in mode with schema). - Add missing service fields (find out which fields are required and which are not).
- Add (rename) some fields (
oldImage
—before
,newImage
—after
, etc).