anchor.diff:      "source": {
         "version": "{debezium-version}",
         "name": "mysql-server-1",
  +      "connector": "mysql",
  +      "name": "mysql-server-1",
  +      "ts_ms": 1465581,
  +      "snapshot": false,
  +      "db": "inventory",
  +      "table": "customers",
         "server_id": 223344,
  -      "ts_sec": 1465581,
         "gtid": null,
         "file": "mysql-bin.000003",
         "pos": 484,
         "row": 0,
  -      "snapshot": false,
         "thread": 7,
  -      "db": "inventory",
  -      "table": "customers",
         "query": "UPDATE customers SET first_name='Anne Marie' WHERE id=1004"
       },
       "op": "u",
  
positive.code: {
    "schema": {
      "type": "struct",
      "optional": false,
      "name": "mysql-server-1.inventory.customers.Envelope",
      "version": 1,
      "fields": [
        {
          "field": "op",
          "type": "string",
          "optional": false
        },
        {
          "field": "before",
          "type": "struct",
          "optional": true,
          "name": "mysql-server-1.inventory.customers.Value",
          "fields": [
            {
              "type": "int32",
  
negative.code:     "after": null,
      "source": {
        "version": "{debezium-version}",
        "connector": "mysql",
        "name": "mysql-server-1",
        "ts_ms": 1465581,
        "snapshot": false,
        "db": "inventory",
        "table": "customers",
        "server_id": 223344,
        "gtid": null,
        "file": "mysql-bin.000003",
        "pos": 805,
        "row": 0,
        "thread": 7,
        "query": "DELETE FROM customers WHERE id=1004"
      },
      "op": "d",
  