Skip to content

Instantly share code, notes, and snippets.

@oolongtea
Last active June 29, 2021 17:40
Show Gist options
  • Save oolongtea/06c1b9d8094cd711e5ba480174bb7725 to your computer and use it in GitHub Desktop.
Save oolongtea/06c1b9d8094cd711e5ba480174bb7725 to your computer and use it in GitHub Desktop.
Example Debezium CDC record in Snowflake
// record_metadata
{
"CreateTime": 1595535726000,
"key": "{\"id\":1}",
"offset": 4000,
"partition": 2,
"topic": "debezium.myschema.video"
}
//record_content
{
"after": {
"created_at": 1519212232000,
"id": 2,
"user_id": 500,
"video_title": "Cat Video",
},
"before": null,
"op": "r",
"source": {
"connector": "mysql",
"db": "mydb",
"file": "mysql-binlog.001001",
"gtid": null,
"name": "debezium",
"pos": 45046200,
"query": null,
"row": 0,
"server_id": 0,
"snapshot": true,
"table": "video",
"thread": null,
"ts_sec": 0,
"version": "0.9.5.Final"
},
"ts_ms": 1595534726000
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment