ArkFlow
High-performance Rust stream processing engine
High Performance
Built on Rust and Tokio async runtime, offering excellent performance and low latency.
Multiple Data Sources
Support for Kafka, MQTT, HTTP, files, and other input/output sources.
Powerful Processing Capabilities
Built-in SQL queries, JSON processing, Protobuf encoding/decoding, batch processing, and other processors.
Extensible
Modular design, easy to extend with new input, output, and processor components.