✨ New feature

Partial backfills

✨ New feature

Partial backfills

The fastest Postgres change data capture

(that's actually correct)

Stream data from Postgres directly to Kafka, Redis, and more. Replace complex tools like Debezium and consolidate workflows.

Capture every insert, update, and delete

Works with any Postgres database:

Real-time sink to streams, queues, and more:

Built-in backfills, filters, routing, and transforms

Open source, MIT license

Get Started with OSS

Try Sequin for Free

YAML

CLI

API

databases:

- name: "sequin-playground"

username: "postgres"

password: "postgres"

hostname: "sequin_postgres"

database: "sequin_playground"

port: 5432

slot_name: "sequin_slot"

publication_name: "sequin_pub"

tables:

- table_name: "accounts"

table_schema: "public"

sort_column_name: "updated_at"

sinks:

- name: "kafka-sink"

database: "sequin-playground"

table: "public.accounts"

destination:

type: "kafka"

hosts: "kafka1.example.com:9092"

topic: "accounts-topic"

username: "kafka-user"

password: "kafka-password"

sasl_mechanism: "plain"

Read case study

Performance

Industry-leading performance

Sequin is tuned to Postgres to provide industry-leading performance. If your database can handle the transaction, Sequin will deliver it with minimal overhead. Read more on our benchmarking page →

40,000+

messages per second

40+ MB/s

bandwidth throughput

55ms

average latency

Real-time CDC

Postgres to Kafka

Latency at 10,000 operations / second

6.8x

Sequin · 55 ms

AWS MSK Debezium · 253 ms

Fivetran · 5 min

AirByte · 1+ hours

Guarantees

Capture & deliver
every change

Simplify your architecture by building on strong guarantees. Sequin never misses an insert, update, or delete and delivers every (100%) change to your stream or queue.

Real-time

Sequin uses logical replication to capture every change.

Real-time

Sequin uses logical replication to capture every change.

Real-time

Sequin uses logical replication to capture every change.

Strict ordering

Rows are delivered in a strict order.

Strict ordering

Rows are delivered in a strict order.

Strict ordering

Rows are delivered in a strict order.

100% delivery

Every change in your database is delivered to your sink.

100% delivery

Every change in your database is delivered to your sink.

100% delivery

Every change in your database is delivered to your sink.

Use cases

Streamline your use case

Sequin is designed to power every change data capture use case. No need to master a new piece of infrastructure.

Trigger

Workflows

Create

Audit logs

Sync

Search

Replicate

Tables

Send

Webhooks

Maintain

Caches

// Handle order events and trigger workflows async function handleOrderWorkflow(change) { // Log the change await logDatabaseChange(change); // Only process new orders if (change.metadata.table_name === 'orders' && change.action === 'insert') { const order = change.record; // Update inventory for each item for (const item of order.items) { await updateInventory(item.product_id, -item.quantity); } } } // Update inventory levels and check thresholds async function updateInventory(productId, quantityChange) { const { rows } = await db.query( 'UPDATE inventory SET quantity = quantity + $1 WHERE product_id = $2 RETURNING quantity', [quantityChange, productId] ); // Trigger alert if inventory is low if (rows[0].quantity <= 10) { await db.query( 'INSERT INTO inventory_alerts (product_id, current_quantity) VALUES ($1, $2)', [productId, rows[0].quantity] ); } }

Trigger code when Postgres rows change

Build automated workflows from database changes. Sequin captures and delivers every change in your database so you can break monolithic processes into automated, event-driven workflows.

Learn how →

Features

Setting a higher standard

Change data capture typically requires adding complicated dependencies, endless configuration, and blackbox runtimes. Sequin is tailored to Postgres to cut out the complexity and deliver helpful features.

SQL filters

Use WHERE clauses to route changes to your sinks.

def transform(action, record, changes, metadata) do first_name = record["first_name"] last_name = record["last_name"] full_name = first_name <> " " <> last_name %{ full_name: full_name } end

def transform(action, record, changes, metadata) do first_name = record["first_name"] last_name = record["last_name"] full_name = first_name <> " " <> last_name %{ full_name: full_name } end

Transforms

Transform messages.

Web Console

A rich web console to easily manage and observe sinks as you build.

Trace every row from capture through to delivery.

Backfill

Backfill at any time.

Observable

Trace every row from capture through to delivery.

Prometheus Metrics + Grafana Dashboard

Metrics

Plug Sequin into your monitoring and metrics.

Plug Sequin's prometheus endpoint into your monitoring.

Integrations

Drop into your stack

Works with your framework

Sequin works with any Postgres database (version 14+) and supports a growing list of sinks to queues and streams. Sequin even supports native sinks (Webhooks and HTTP) so you can get started without any other infrastructure.

AnyPostgres

Any

Postgres

Stream & Queues

Caches & Search

Testimonials

Loved by developers

"Sequin eliminated the headache of manually syncing Postgres to Typesense. Their transformation functions effortlessly handle complex workflows like triggering translation requests on content updates. Now we have reliable, real-time search sync without any maintenance overhead."

Isaac R.

Head of Tech

"We found Debezium to be a complex solution that demands significant technical expertise to get right. In contrast, Sequin is much more straightforward and intuitive—it just works, and with fewer resources required."

Alexey Z.

VP of Engineering

"Sequin completely changed how YouTrip tracks changes in our system. It just works! Zero delivery issues, no snapshotting problems, and no random memory spikes. The whole team was impressed by how easy it was to set up, and we haven't had to think about it since."

Gowtham M.

Senior Software Engineer

"Sequin was incredibly easy to setup and allowed us to quickly establish our real-time knowledge base pipeline. It just works - letting our engineers focus on building features instead of maintaining complicated data infrastructure."

Jinyuan L.

Lead AI Engineer

"Sequin solved our activity feed scaling challenges. Its use of logical replication means our application commits changes faster, as it no longer waits for synchronous audit log writes. With features like transaction annotations, we're able to capture rich context like exactly who made each change. I love what these guys are doing!"