Streaming & CDC

Data in and out, continuously.

WHAT'S INSIDE

CREATE STREAMING PIPELINE — Kafka, Kinesis, NATS
Exactly-once ingest with DEDUP KEY, backpressure, dead-lettering
Arrow Flight SQL endpoint — queries + bulk ingest (port 5434)
CREATE CHANGEFEED — Debezium-style JSON envelopes*
PostgreSQL logical-replication wire + binary COPY

*In development — not yet production-ready.

streaming pipeline

CREATE STREAMING PIPELINE tick_pipeline
  SOURCE KAFKA (brokers='localhost:9092', topic='ticks', group_id='ezradb')
  INTO si_ticks FORMAT JSON DEDUP KEY (sym, ts);

THE REST OF THE ENGINE

Transactional engineA serious OLTP core — MVCC, WAL, real Postgres semantics.

Analytical engineA vectorized columnar warehouse living in the same database.

HTAP fabricBoth engines over one MVCC timeline. Pick per table, keep one copy.

Time-series & quantA kdb-class time engine that speaks SQL.

Redis-compatible KV & queuesA cache and job-queue engine inside your database.

Search & AIFull-text and vectors without another system.

In-database computeBring the code to the data — JavaScript today, distributed & GPU next.

Resilience & scaleSpanner-class ambitions, engineered in the open of our roadmap.

Security & operationsRun it like Postgres. Watch it like a modern system.

← Everything inside the engine See the benchmarks →