Sequin is a tool for change data capture (CDC) in Postgres. Sequin makes it easy to stream Postgres rows and changes to streaming platforms and queues (e.g. Kafka and SQS). You can backfill existing rows and stream new changes in real-time.
Sequin even supports native sinks (HTTP GET and webhooks), so you can get started without any other infrastructure.
Change data capture enables applications and services to track and respond to row-level changes in database tables as they occur. With CDC via Sequin, you can:
- Replicate data from your existing tables to other apps, databases, caches, materialized views, or frontend clients.
- Build event driven workflows such as triggering side effects when data in Postgres changes.
Sequin itself is built on Postgres. It uses a logical replication slot to detect changes and internal tables to store sink state.
Unlike Debezium, another change data capture tool, Sequin doesn't require Kafka to operate. Sequin is a standalone Docker container that you can deploy next to your Postgres database. Or, you can use our hosted offering.
Sequin is open source/MIT. To help us make this project great, tell us what you're building in our Discord Server.
| Sink | Support | Description |
|---|---|---|
| Kafka | ✅ Real-time streaming ✅ Backfill existing rows |
Stream changes to Apache Kafka topics |
| SQS | ✅ Real-time streaming ✅ Backfill existing rows |
Send messages to Amazon SQS queues |
| Redis | ✅ Real-time streaming ✅ Backfill existing rows |
XADD to Redis Streams |
| Webhook Subscription (Native) | ✅ Real-time streaming ✅ Backfill existing rows |
Send changes to any HTTP endpoint |
| HTTP Pull (Native) | ✅ Real-time streaming ✅ Backfill existing rows |
Consume changes directly from Sequin with exactly-once processing |
| GCP Pub/Sub | ✅ Real-time streaming ✅ Backfill existing rows |
Publish messages to Google Cloud Pub/Sub topics |
| NATS | ✅ Real-time streaming ✅ Backfill existing rows |
Stream changes to NATS subjects |
| RabbitMQ | ✅ Real-time streaming ✅ Backfill existing rows |
Publish messages to RabbitMQ exchanges |
| Azure EventHubs | Coming soon | (Late Dec 2024) |
| Amazon SNS | Coming soon | (Jan 2025) |
| AWS Kinesis | Coming soon | (Jan 2025) |
- Never miss a change: Sequin ensures all database changes are delivered to sinks.
- SQL-based routing: Filter and route messages to sinks using SQL
whereconditions. - Backfills: Backfill existing rows from your tables to sinks.
- Bring your database: Sequin is not an extension. It works with any Postgres database version 12+.
- Transforms (coming soon!): Transform message payloads by writing functions in Lua, JavaScript, or Go.
Sequin works great for change data capture use cases like:
- Triggering a workflow when data changes in Postgres: Execute custom business logic whenever specific rows are inserted, updated, or deleted in your database.
- Making events available to downstream services: Stream changes from your database tables as events that other services can consume.
- Informing downstream services when rows change: Notify dependent services about data changes to keep systems in sync.
- Audit logging: Track and record all changes made to data in your database for compliance or feature development.
- Sync a table from one database to another: Keep tables synchronized across different database instances in real-time.
- Materializing another table in your database: Create and maintain derived tables based on changes to source tables.
- Maintaining a cache: Keep caches up-to-date by streaming database changes.
- Refreshing search indexes: Keep search indexes fresh by streaming updates from your database.
See our quickstart.
Alternatively, you can try Sequin for free on Sequin Cloud. Follow the instructions in the app to start streaming your data in a couple minutes.
Sequin connects to any Postgres database. Specify the tables you want to stream, as well as optional filters and transformations. Route changes to sinks like Kafka, SQS, Redis, or HTTP endpoints.
When you setup a sink, you can opt to backfill data from the source table to the sink.
After setup, Sequin will stream new changes to the sink as they occur in real-time. If there are any issues with delivery, Sequin will automatically retry delivery with exponential backoff.
Sequin comes with a web console/UI for configuration.
You can also configure Sequin as code using YAML config files.
Sequin delivers industry-leading performance for change data capture (CDC), consistently achieving sub-200ms latency at 2,000 sustained operations per second. Here's how Sequin compares to other solutions:
| Tool | Latency at 2k ops/s |
|---|---|
| Sequin | 192ms |
| Debezium | 234ms |
| Fivetran | 5 minutes |
| Airbyte | 1+ hours |
In our production benchmarks with AWS RDS Postgres and MSK Kafka, Sequin maintains consistent performance under sustained load:
- Average throughput: 2,054.4 ops/sec
- Average latency: 192ms
- 99th percentile latency: 245ms
Learn more about Sequin's current performance in our docs.
Sequin vs Debezium
Debezium is also a change data capture tool that captures changes from Postgres and streams them to messaging systems like Kafka. Debezium requires significant infrastructure (Kafka, Connect) to operate.
Sequin provides the same change data capture capabilities but with a much simpler setup:
- No Kafka required: Sequin doesn't require Kafka.
- Native destinations: With Debezium, you route to destinations via Kafka Connect. With Sequin, you stream directly to your destination of choice. This means simpler setup, fewer transforms, and fewer moving parts.
- Full-featured web console: Sequin includes a web console for configuration and monitoring.
Sequin vs Fivetran/Airbyte
Fivetran and Airbyte are ETL tools designed primarily for data warehouse ingestion. They excel at moving data in batch intervals (minutes to hours) to analytical databases.
Sequin is purpose-built for real-time operational use cases. Key differences:
- Real-time streaming: Versus batch intervals.
- Focus on operational destinations: Queues, streams, webhooks, etc. vs data warehouses.
- Flexible backfills: Deployed a bug and need to replay the last 2 hours of data? Sequin makes it easy.
Sequin vs custom change data capture solutions
Many teams build custom change data capture solutions using triggers, LISTEN/NOTIFY, or logical replication. While these can work, they often:
- Lack exactly-once processing guarantees
- Don't scale
- Don't handle backfills well
- Need ongoing maintenance
- Become a burden when the engineer who built it leaves the team
Sequin provides all this functionality out of the box:
- Exactly-once processing
- Seamless backfills
- Automatic retries and error handling
- Simple monitoring and observability
- Zero maintenance of change data capture infrastructure
Sequin is open source (MIT license). The project is just getting started, so the best way to contribute right now is to open an issue or join the Discord Server and let us know what you want to build.