Streambed – Stream Postgres to Iceberg on S3, Supports Postgres Wire
Query Iceberg tables directly via psql without spinning up Trino or Spark clusters.
Speaks native WAL protocol with zero database triggers or persistent slots.
Backend engineers building live read models or cache invalidation
Debezium · Postgres LISTEN/NOTIFY · Hasura Event Triggers
pgnudge is a small async Python library that tells you which tables just changed in Postgres, so a cache or read model can refetch the moment the data moves. No row data - it tells you when and what to reload, you already know how to load it.
It leaves nothing persistent on the server (temp replication slot, dropped when the session ends) and needs no database driver — it speaks the walsender protocol itself. One dependency.
Not CDC (no before/after rows), not a queue (no durability). It moves wakefulness, not rows or work.
Query Iceberg tables directly via psql without spinning up Trino or Spark clusters.
FastAPI-style ergonomics for background jobs with auto-generated AsyncAPI docs.
Unified sync/async stream API handles concurrency, throttling, batching without dependencies.
Ephemeral ClickHouse on demand beats Kafka pipelines — but early access limits confidence.
FK-preserving pseudonymization that pg_anonymize and Tonic don't handle coherently.
LangChain alternative with 2 dependencies in an already crowded framework space.