Replication Engine: Online // Sub-second CDC

YOUR DATABASE. GOOGLE CLOUD. UNDER 100MS.

Stream every database change to Google Cloud in under 100ms. One binary. Predictable pricing.

Get Started Free
Single binary · no per-row pricing + Free forever tier
Pipeline Monitor
3 Active
orders-to-bigquery
RUNNING
postgres → bigquery lag: 72ms
events-to-clickhouse
RUNNING
mysql → snowflake lag: 48ms
users-to-iceberg
RUNNING
mongodb → iceberg lag: 88ms
Throughput
2.4M
events/s
Avg Lag
72ms
end-to-end
Checkpoint
LSN+3
committed
10:42:01WAL decoder: LSN 0/3A1B2C4D received
10:42:01orders INSERT → ArrowRecord[124 rows]
10:42:01AdaptiveBuffer flush triggered (size gate)
10:42:01BigQuery committed: offset 4,821 → 4,945
10:42:02Schema drift check: orders — no changes
10:42:02checkpoint saved: LSN 0/3A1B2C4D
10:42:02WARN: replication lag spike 42ms → resolved
10:42:03users UPDATE → ArrowRecord[87 rows]
10:42:03Iceberg committed: snapshot 8a4f2c
10:42:01WAL decoder: LSN 0/3A1B2C4D received
10:42:01orders INSERT → ArrowRecord[124 rows]
10:42:01AdaptiveBuffer flush triggered (size gate)
10:42:01BigQuery committed: offset 4,821 → 4,945
10:42:02checkpoint saved: LSN 0/3A1B2C4D
vs. competitors: Fivetran: 15 mins to 1hr+ Airbyte: 15 mins to 1hr+
nanosync: <100MS · single binary
// Development

Ship in
Minutes

A single statically linked binary. Drop it anywhere — local, Docker, or Kubernetes. Zero runtime dependencies.

01
Install

Single binary, any platform

Homebrew
brew install nanosync/tap/nanosync
curl
curl -fsSL https://nanosync.dev/install.sh | sh
Docker
docker pull nanosync/nanosync:latest
02
Create

Pipeline in seconds

Prompt
"replicate orders to bigquery, mask customer_email"
→ config generated · validated · deployed
source: postgres.orders
sink: bigquery.orders_replica
mask: [customer_email]
Command line
$ nanosync create pipeline \
--source postgres://prod-db/orders \
--sink   bigquery://acme/analytics \
--tables public.*
✓ pipeline created
03
Monitor

Start and watch live progress

Start server
$ nanosync serve --config pipeline.yaml
✓ nanosync v0.1.0 listening on :7600
Web UI: http://localhost:7600/app
Live status
$ nanosync list pipelines
NAME STATUS LAG EVENTS
orders-to-bigquery streaming <100ms 18.4k
replication live · snapshot complete · no errors
// Operations

Built for
Sub-second Latency

Every component designed to never be the bottleneck — from log decoder to sink writer, with the reliability and intelligence to run itself.

// Intelligence

Anomaly Detection

Pre-emptive alerts 5–15 min before failure. Continuous trend analysis on lag, throughput, and error rate — the platform pages you before users notice.

LAG SPIKE · orders_pipeline ALERT · 9 MIN EARLY
THROUGHPUT DROP · 34% INVESTIGATING
ERROR RATE · payments_sink RESOLVED · NO PAGE
WAL BACKLOG · 2.1M events ALERT · 12 MIN EARLY

Natural Language Pipelines

"Replicate orders to BigQuery, mask email" → config generated, validated, and deployed. No YAML required.

Prompt
"replicate orders to bigquery, mask customer_email"
config generated · validated · deployed
source: postgres.orders
sink: bigquery.orders_replica
mask: [customer_email]

Self-Tuning Engine

AdaptiveBuffer thresholds and batch sizes optimised continuously based on live traffic patterns. No manual tuning.

batch_size 1000 → 1847
flush_interval 100ms → 67ms
worker_concurrency 4 → 7
throughput delta +38%
// Reliability
Schema_Governance

Schema Drift Handled

Every schema change is classified. Backward-compatible widenings are auto-applied. Breaking changes gate on human approval. Nothing surprises your warehouse.

ADD COLUMN (nullable)AUTO-APPLIED
INT → BIGINTAUTO-APPLIED
DROP COLUMNAPPROVAL REQUIRED
TYPE NARROWINGAPPROVAL REQUIRED
Observability

30+ OTel Instruments

OpenTelemetry metrics via Prometheus bridge. Named instruments across pipeline, sink, source, worker, and scheduler subsystems. Grafana dashboards included.

Uptime SLA
99.9%
Enterprise tier
Checkpoints
0
per minute
Run history
90d
Enterprise tier
Instruments
30+
OTel metrics
Compliance_Log

Enterprise Security

RBAC, SSO, and audit logging for teams operating in regulated environments. PII masking and SOC 2 compliance on the roadmap.

RBAC + SSO (SAML/OIDC)Enterprise
Audit log (actor + diff)Enterprise
PII detection + maskingRoadmap
SOC 2 audit exportRoadmap
// Connector_Matrix

Any Source
Any Sink

All sources and all sinks are included on every plan. Don't pay for connectors anymore.

Databases
PostgreSQL Postgres
MySQL MySQL
SQL Server SQL Server
MongoDB MongoDB
DynamoDB DynamoDB
Cloud SQL Cloud SQL
AlloyDB AlloyDB
Spanner Spanner
BigQuery BigQuery
Snowflake Snowflake
Storage
S3 S3
GCS GCS
Redshift Redshift
Iceberg Iceberg
Parquet Parquet
Avro Avro
JSONL / CSV
Messaging
Kafka Kafka
Pub/Sub Pub/Sub
// Pricing

Start Free.
Scale Autonomously.

Every plan includes all sources and all sinks. Upgrade when you need reliability, RBAC, or AI autonomy — not to unlock connectors.

Standard

$0 / forever
10M events / month

Prove the latency. All sources and sinks included. Get started in minutes with no credit card.

  • All sources + all sinks
  • 10M events / month
  • Single-node deployment
  • Community support
Download

Business

Custom
 

Multi-node HA, RBAC + SSO, WASM transforms, schema drift approval, 90-day history, custom alerts. Self-hostable, air-gap ready.

  • Everything in Standard
  • Multi-node HA
  • RBAC · SAML 2.0 · OIDC
  • Support with SLAs
Join Waitlist

Enterprise

Custom
 

The autonomous layer. Anomaly detection, natural language pipelines, self-tuning, PII masking, compliance packs, data catalog integration.

  • Everything in Business
  • AI Agents
  • Anomaly detection
  • Self-tuning engine
  • Customer success manager
Join Waitlist