$ nats consumer add DebeziumStream viewer --ephemeral --pull --defaults > /dev/null
$ nats consumer next --raw --count 100 DebeziumStream viewer | jq -r '.payload'
{
"before": null,
"after": {
"user_id": 4,
"username": "user2",
"password": "beseeingya",
"email": "user2@email.com",
"created_on": 1700505308855573,
"last_login": null
},
"source": {
"version": "2.2.0.Alpha3",
"connector": "postgresql",
"name": "glassflowtopic",
"ts_ms": 1700505308860,
"snapshot": "false",
"db": "glassflowdb",
"sequence": "[\"26589096\",\"26597648\"]",
"schema": "public",
"table": "accounts",
"txId": 742,
"lsn": 26597648,
"xmin": null
},
"op": "c",
"ts_ms": 1700505309220,
"transaction": null
}
{
"before": {
"user_id": 3,
"username": "",
"password": "",
"email": "",
"created_on": 0,
"last_login": null
},
"after": null,
"source": {
"version": "2.2.0.Alpha3",
"connector": "postgresql",
"name": "glassflowtopic",
"ts_ms": 1700505331733,
"snapshot": "false",
"db": "glassflowdb",
"sequence": "[\"26598656\",\"26598712\"]",
"schema": "public",
"table": "accounts",
"txId": 743,
"lsn": 26598712,
"xmin": null
},
"op": "d",
"ts_ms": 1700505331751,
"transaction": null
}
Comments