hey! If i am creating a new replication slot for a...
# singer-taps
k
hey! If i am creating a new replication slot for an old CDC tap (
tap-postgres-pipelinewise
) running logical replication from postgres to snowflake, do i need to update the state of the tap to match the lsn of the new replication slot? We dropped the old to use
wal2json
. In general, the old tap was running fine, but since it is going to consume a new replication slot I was wondering what process we have to go through to not lose records. Thanks in advance!
so more specifically, should we update the lsn of all the tables / streams in the state to match the
confirmed_flush_lsn
of the replication slot?