Data streaming

PGSync — Real-time PostgreSQL replication

Stream PostgreSQL changes into standard Apache Iceberg tables, built in Rust.

Kafka broker embedded in postgres

Kafka and Durable streams on object storage

Pluggable data replication with checkpointing, batching, and integrity events

Minimal, pure clojure, data-driven NATS client

Data streaming runtime focused on performance, consistency, and extensibility. Write plugins in Rust or WASM and process data with data guarantees.

Sub-second Postgres replication to ClickHouse using physical WAL

An async messaging framework for Rust

A distributed event processing pipeline built in Go

Distributed event stream server over HTTP, backed by S3.

Real-time PostgreSQL WAL reader built in GO - captures INSERT, UPDATE, DELETE using logical replication

DSX Exchange

kaptanto captures every insert, update, and delete from Postgres and MongoDB the moment it happens... and delivers it via stdout, SSE, gRPC or 5 different queue sinks. One static binary. Self-contained. Deploys anywhere.

PgQue – Zero-bloat Postgres queue built on top of on battle-proven Skype's PgQ. One SQL file to install, pg_cron to tick https://pgque.dev

Stream Postgres to Apache Iceberg on S3 via logical replication, queryable over the Postgres wire protocol.

Blob stream

A desktop Kafka client for developers who want clarity, not complexity