dozer
dozer copied to clipboard
Postgres connector cannot resume if no events in CDC stream received
This bug happens when we don't receive any message in CDC stream after reading the initial snapshot of data in postgres database. In this case, we have LSN of publication slot, which can be used for snapshotting done event.
https://link.excalidraw.com/readonly/cBRn1ElaavxaTJtJ6CvP
Yes, we should send a Some(OpIdentifier::new(lsn, MAGIC_NUMBER)) to make it resumable once snapshotting is done.