Sample debezium events

debezium.md

Update Events

{
  "before": {
    "id": 107,
    "name": "1111438344",
    "description": "box of assorted rocks",
    "weight": 5.300000190734863
  },
  "after": {
    "id": 107,
    "name": "111143834", // <----
    "description": "box of assorted rocks",
    "weight": 5.300000190734863
  },
  "source": {
    "version": "1.0.0.Final",
    "connector": "mysql",
    "name": "dbserver1",
    "ts_ms": 1623365729000,
    "snapshot": "false",
    "db": "inventory",
    "table": "products",
    "server_id": 223344,
    "gtid": null,
    "file": "mysql-bin.000003",
    "pos": 1437,
    "row": 0,
    "thread": 5,
    "query": null
  },
  "op": "u",
  "ts_ms": 1623365729436
}

Insert Events

{
  "before": null,
  "after": {
    "id": 110,
    "name": "diapers",
    "description": "what my baby needs",
    "weight": 2
  },
  "source": {
    "version": "1.0.0.Final",
    "connector": "mysql",
    "name": "dbserver1",
    "ts_ms": 1623366037000,
    "snapshot": "false",
    "db": "inventory",
    "table": "products",
    "server_id": 223344,
    "gtid": null,
    "file": "mysql-bin.000003",
    "pos": 2233,
    "row": 0,
    "thread": 5,
    "query": null
  },
  "op": "c",
  "ts_ms": 1623366037875
}

Delete events

{
  "before": {
    "id": 110,
    "name": "diapers",
    "description": "what my baby needs",
    "weight": 2
  },
  "after": null,
  "source": {
    "version": "1.0.0.Final",
    "connector": "mysql",
    "name": "dbserver1",
    "ts_ms": 1623366300000,
    "snapshot": "false",
    "db": "inventory",
    "table": "products",
    "server_id": 223344,
    "gtid": null,
    "file": "mysql-bin.000003",
    "pos": 2544,
    "row": 0,
    "thread": 5,
    "query": null
  },
  "op": "d",
  "ts_ms": 1623366300257
}