Implement exactly-once processing for Postgres events without additional infrastructure. Learn how to use Sequin’s HTTP-based stream to pull database changes.
insert
, update
, and delete
changes in a buffer table until they’re delivered to your consumer.
You can use change retention to persist changes to a table in your database. Then, you can stream that table to your consumer. This gives you the power to run backfills/replays of recent changes at any time. This can be handy: for example, if you realize there’s a bug in your message handling implementation, you can deploy the fix and re-process changes from the last few minutes or days.
Select source tables
Add filters (optional)
Add transform (optional)
Specify backfill
Specify message grouping
Specify visibility timeout
Specify max ack pending
Specify max waiting
Create the sink
acknowledged
in the Sequin web console.