Skip to content

Instantly share code, notes, and snippets.

@agiri23
Last active March 21, 2022 15:45
Show Gist options
  • Save agiri23/d718297081efccca9828149f43b091af to your computer and use it in GitHub Desktop.
Save agiri23/d718297081efccca9828149f43b091af to your computer and use it in GitHub Desktop.
{
"schema": {
"type": "struct",
"fields": [{
"type": "struct",
"fields": [{
"type": "int32",
"optional": false,
"field": "id"
}, {
"type": "string",
"optional": true,
"field": "first_name"
}, {
"type": "string",
"optional": true,
"field": "last_name"
}, {
"type": "string",
"optional": true,
"field": "email"
}, {
"type": "int32",
"optional": true,
"field": "mobile"
}],
"optional": true,
"name": "dbserver1.debezium.customers.Value",
"field": "before"
}, {
"type": "struct",
"fields": [{
"type": "int32",
"optional": false,
"field": "id"
}, {
"type": "string",
"optional": true,
"field": "first_name"
}, {
"type": "string",
"optional": true,
"field": "last_name"
}, {
"type": "string",
"optional": true,
"field": "email"
}, {
"type": "int32",
"optional": true,
"field": "mobile"
}],
"optional": true,
"name": "dbserver1.debezium.customers.Value",
"field": "after"
}, {
"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": "string",
"optional": true,
"name": "io.debezium.data.Enum",
"version": 1,
"parameters": {
"allowed": "true,last,false,incremental"
},
"default": "false",
"field": "snapshot"
}, {
"type": "string",
"optional": false,
"field": "db"
}, {
"type": "string",
"optional": true,
"field": "sequence"
}, {
"type": "string",
"optional": true,
"field": "table"
}, {
"type": "int64",
"optional": false,
"field": "server_id"
}, {
"type": "string",
"optional": true,
"field": "gtid"
}, {
"type": "string",
"optional": false,
"field": "file"
}, {
"type": "int64",
"optional": false,
"field": "pos"
}, {
"type": "int32",
"optional": false,
"field": "row"
}, {
"type": "int64",
"optional": true,
"field": "thread"
}, {
"type": "string",
"optional": true,
"field": "query"
}],
"optional": false,
"name": "io.debezium.connector.mysql.Source",
"field": "source"
}, {
"type": "string",
"optional": false,
"field": "op"
}, {
"type": "int64",
"optional": true,
"field": "ts_ms"
}, {
"type": "struct",
"fields": [{
"type": "string",
"optional": false,
"field": "id"
}, {
"type": "int64",
"optional": false,
"field": "total_order"
}, {
"type": "int64",
"optional": false,
"field": "data_collection_order"
}],
"optional": true,
"field": "transaction"
}],
"optional": false,
"name": "dbserver1.debezium.customers.Envelope"
},
"payload": {
"before": null,
"after": {
"id": 3,
"first_name": "nobody",
"last_name": "nobody",
"email": "nobody@datapebbles.com",
"mobile": 123
},
"source": {
"version": "1.8.1.Final",
"connector": "mysql",
"name": "dbserver1",
"ts_ms": 1647876062000,
"snapshot": "false",
"db": "debezium",
"sequence": null,
"table": "customers",
"server_id": 1,
"gtid": null,
"file": "binlog.000004",
"pos": 2282,
"row": 0,
"thread": null,
"query": null
},
"op": "c",
"ts_ms": 1647876062716,
"transaction": null
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment