anchor.diff:  * `d` = delete
   * `r` = read (applies to only snapshots)
   
  -|5
  +|7
   |`ts_ms`
   a| Optional field that displays the time at which the connector processed the event. The time is based on the system clock in the JVM running the Kafka Connect task.
   
  -|6
  +|8
   |`before`
   | An optional field that specifies the state of the row before the event occurred. When the `op` field is `c` for create, as it is in this example, the `before` field is `null` since this change event is for new content. 
   
  -|7
  +|9
   |`after`
   | An optional field that specifies the state of the row after the event occurred. In this example, the `after` field contains the values of the new row's `id`, `first_name`, `last_name`, and `email` columns.
   
  -|8
  +|10
   |`source`
   a| Mandatory field that describes the source metadata for the event. This field contains information that you can use to compare this event with other events, with regard to the origin of the events, the order in which the events occurred, and whether events were part of the same transaction. The source metadata includes: 
   
  
positive.code:       }
      ],
      "optional": false,
      "name": "mysql-server-1.inventory.customers.Envelope" // <2>
    },
    "payload": { // <3>
      "op": "c", // <4>
      "ts_ms": 1465491411815, // <5>
      "before": null, // <6>
      "after": { // <7>
        "id": 1004,
        "first_name": "Anne",
        "last_name": "Kretchmar",
        "email": "annek@noanswer.org"
      },
      "source": { // <8>
        "version": "{debezium-version}",
        "connector": "mysql",
        "name": "mysql-server-1",
  
negative.code:           }
          ],
          "optional": true,
          "name": "mysql-server-1.inventory.customers.Value", 
          "field": "after"
        },
        {
  