anchor.diff:                          "optional": false,
                           "field": "email"
                       }
  -                ]
  +                ],
  +                "optional": true,
  +                "name": "PostgreSQL_server.inventory.customers.Value",
  +                "field": "before"
               },
               {
  -                "field": "source",
                   "type": "struct",
  -                "name": "io.debezium.connector.postgresql.Source",
  -                "optional": false,
                   "fields": [
                       {
  -                        "name": "version",
  -                        "index": "0",
  -                        "schema": {
  -                            "type": "STRING",
  -                            "optional": "false"
  -                        }
  +                        "type": "int32",
  +                        "optional": false,
  +                        "field": "id"
                       },
                       {
  -                        "name": "name",
  -                        "index": "1",
  -                        "schema": {
  -                            "type": "STRING",
  -                            "optional": "false"
  -                        }
  +                        "type": "string",
  +                        "optional": false,
  +                        "field": "first_name"
                       },
                       {
  -                        "name": "db",
  -                        "index": "2",
  -                        "schema": {
  -                            "type": "STRING",
  -                            "optional": "false"
  -                        }
  +                        "type": "string",
  +                        "optional": false,
  +                        "field": "last_name"
                       },
                       {
  -                        "name": "ts_usec",
  -                        "index": "3",
  -                        "schema": {
  -                            "type": "INT64",
  -                            "optional": "true"
  -                        }
  -                    },
  -                    {
  -                        "name": "txId",
  -                        "index": "4",
  -                        "schema": {
  -                            "type": "INT64",
  -                            "optional": "true"
  -                        }
  -                    },
  -                    {
  -                        "name": "lsn",
  -                        "index": "5",
  -                        "schema": {
  -                            "type": "INT64",
  -                            "optional": "true"
  -                        }
  -                    },
  -                    {
  -                        "name": "schema",
  -                        "index": "6",
  -                        "schema": {
  -                            "type": "INT64",
  -                            "optional": "true"
  -                        }
  -                    },
  -                    {
  -                        "name": "table",
  -                        "index": "7",
  -                        "schema": {
  -                            "type": "INT64",
  -                            "optional": "true"
  -                        }
  -                    },
  -                    {
  -                        "name": "snapshot",
  -                        "index": "8",
  -                        "schema": {
  -                            "type": "BOOLEAN",
  -                            "optional": "true"
  -                        }
  -                    },
  -                    {
  -                        "name": "last_snapshot_record",
  -                        "index": "9",
  -                        "schema": {
  -                            "type": "BOOLEAN",
  -                            "optional": "true"
  -                        }
  +                        "type": "string",
  +                        "optional": false,
  +                        "field": "email"
                       }
  -                ]
  +                ],
  +                "optional": true,
  +                "name": "PostgreSQL_server.inventory.customers.Value",
  +                "field": "after"
               },
               {
  -                "field": "ts_ms",
  +                "type": "struct",
  +                "fields": [
  +                    {
  +                        "type": "string",
  +                        "optional": false,
  +                        "field": "version"
  +                    },
  +                    {
  +                        "type": "string",
  +                        "optional": false,
  +                        "field": "connector"
  +                    },
  +                    {
  +                        "type": "string",
  +                        "optional": false,
  +                        "field": "name"
  +                    },
  +                    {
  +                        "type": "int64",
  +                        "optional": false,
  +                        "field": "ts_ms"
  +                    },
  +                    {
  +                        "type": "boolean",
  +                        "optional": true,
  +                        "default": false,
  +                        "field": "snapshot"
  +                    },
  +                    {
  +                        "type": "string",
  +                        "optional": false,
  +                        "field": "db"
  +                    },
  +                    {
  +                        "type": "string",
  +                        "optional": false,
  +                        "field": "schema"
  +                    },
  +                    {
  +                        "type": "string",
  +                        "optional": false,
  +                        "field": "table"
  +                    },
  +                    {
  +                        "type": "int64",
  +                        "optional": true,
  +                        "field": "txId"
  +                    },
  +                    {
  +                        "type": "int64",
  +                        "optional": true,
  +                        "field": "lsn"
  +                    },
  +                    {
  +                        "type": "int64",
  +                        "optional": true,
  +                        "field": "xmin"
  +                    }
  +                ],
  +                "optional": false,
  +                "name": "io.debezium.connector.postgresql.Source",
  +                "field": "source"
  +            },
  +            {
  +                "type": "string",
  +                "optional": false,
  +                "field": "op"
  +            },
  +            {
                   "type": "int64",
  -                "optional": true
  +                "optional": true,
  +                "field": "ts_ms"
               }
  -        ]
  +        ],
  +        "optional": false,
  +        "name": "PostgreSQL_server.inventory.customers.Envelope"
       },
       "payload": {
  -        "op": "c",
  -        "ts_ms": 1465491411815,
           "before": null,
           "after": {
               "id": 1,
  
positive.code:         },
          "source": {
              "version": "{debezium-version}",
              "name": "PostgreSQL_server",
              "db": "postgres",
              "ts_usec": "1482918357011699",
              "txId": "555",
              "lsn": "24023128",
              "schema": "public",
              "table": "customers",
              "snapshot": null,
              "last_snapshot_record": null
          }
      }
  }
  ----
  
negative.code:         "after": null,
          "source": {
              "version": "{debezium-version}",
              "connector": "postgresql",
              "name": "PostgreSQL_server",
              "ts_ms": 1559033904863,
              "snapshot": null,
              "db": "postgres",
              "schema": "public",
              "table": "customers",
              "txId": 556,
              "lsn": 46523128,
              "xmin": null
          },
          "op": "d",
          "ts_ms": 1465581902461
  