vnvo/deltaforge
A versatile, high-performance Change Data Capture (CDC) engine built in Rust. Streams database changes into downstream systems like Kafka, Redis, NATS and etc, giving you full control over routing, transformation, and delivery.
DeltaForge helps engineers and data professionals reliably move real-time changes from databases like MySQL or PostgreSQL into other systems such as Kafka, Redis, or HTTP endpoints. It automatically detects and processes new, updated, or deleted records as they happen, allowing you to react instantly to database events. You can use it to build robust, event-driven applications or keep data synchronized across different platforms without complex custom code.
Use this if you need to capture changes from your operational databases in real-time and stream them to various downstream systems for analytics, caching, or immediate application responses.
Not ideal if you need a full-fledged stream processing engine for complex data transformations and aggregations, as DeltaForge is focused purely on Change Data Capture.
Stars
17
Forks
—
Language
Rust
License
—
Category
Last pushed
Mar 25, 2026
Commits (30d)
0
Get this data via API
curl "https://pt-edge.onrender.com/api/v1/quality/data-engineering/vnvo/deltaforge"
Open to everyone — 100 requests/day, no key needed. Get a free key for 1,000/day.
Higher-rated alternatives
PrefectHQ/prefect
Prefect is a workflow orchestration framework for building resilient data pipelines in Python.
growthbook/growthbook
Open Source Feature Flags, Experimentation, and Product Analytics
koopjs/koop
Transform, query, and download geospatial data on the web.
pathwaycom/pathway
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
dagster-io/dagster
An orchestration platform for the development, production, and observation of data assets.