The Postgres CDC source can lose change events when a checkpoint completes and the replication slot advances…
The Postgres CDC source can lose change events when a checkpoint completes and the replication slot advances…: a task in LegoFlow-SWE (Harbor dataset). During checkpointing, if the source snapshots its current offset and then additional WAL changes are committed to the replication slot before the…
The task
During checkpointing, if the source snapshots its current offset and then additional WAL changes are committed to the replication slot before the checkpoint completion is processed, those changes are skipped when the source resumes or continues. In practice, the first batch of stream events produced after the offset…
Part of Lego-X/LegoFlow-SWE.