This pull request fixes an issue in our Postgres consumer's handling of delete events, which was reported in issue #22.
In delete events, Postgres does not provide columnnames or columnvalues but instead only sends the id of the deleted row along with all column values. Our consumer now correctly captures the id from oldkeys to construct the necessary data for delete events.
Changes:
Updated delete event handling to fetch the id from change["oldkeys"]["keynames"][0] and change["oldkeys"]["keyvalues"][0].
Here's an example of a delete event change object that this fix accommodates:
This pull request fixes an issue in our Postgres consumer's handling of delete events, which was reported in issue #22.
In delete events, Postgres does not provide
columnnames
orcolumnvalues
but instead only sends theid
of the deleted row along with all column values. Our consumer now correctly captures theid
fromoldkeys
to construct the necessary data for delete events.Changes:
id
fromchange["oldkeys"]["keynames"][0]
andchange["oldkeys"]["keyvalues"][0]
.Here's an example of a delete event change object that this fix accommodates: