arkflow-rs/arkflow
High performance Rust stream processing engine seamlessly integrates AI capabilities, providing powerful real-time data processing and intelligent analysis.
ArkFlow helps you process continuous streams of data from various sources like Kafka, MQTT, or databases in real time. It takes in live data, applies rules you define (like SQL queries or AI models for anomaly detection), and sends the processed information to other systems or dashboards. This is ideal for operations engineers, data analysts, or IoT specialists who need immediate insights from fast-moving data.
1,256 stars. Actively maintained with 4 commits in the last 30 days.
Use this if you need to analyze or transform high volumes of streaming data instantly and react to events as they happen.
Not ideal if your data comes in large, infrequent batches or if you only need occasional reporting rather than real-time insights.
Stars
1,256
Forks
41
Language
Rust
License
Apache-2.0
Category
Last pushed
Mar 11, 2026
Commits (30d)
4
Get this data via API
curl "https://pt-edge.onrender.com/api/v1/quality/data-engineering/arkflow-rs/arkflow"
Open to everyone — 100 requests/day, no key needed. Get a free key for 1,000/day.
Related tools
strake-data/strake
The Data Layer for AI. A high-performance federated SQL engine that gives AI agents governed,...
weld-project/weld
High-performance runtime for data analytics applications
idlab-discover/RustiFlow
Flow feature extraction tool built in Rust using eBPF
torchforge-rs/torchforge-data
Zero-copy, streaming data pipeline for edge-native machine learning in Rust.
SunDoge/fastdata
Fast Data Pipeline with TFRecord and io-uring