ArkFlow English | 中文 is a high-performance Rust stream processing engine that is not yet production-ready. It offers powerful data stream processing capabilities supporting multiple input/output sources and processors. Built on Rust and Tokio async runtime, it provides excellent performance and low latency. Key features include support for Kafka, MQTT, HTTP, files, and other input/output sources, as well as built-in SQL queries, JSON processing, Protobuf encoding/decoding, and batch processing. The engine is modular and extensible, allowing for easy extension with new components. Configuration is done using YAML files. ArkFlow is licensed under the Apache License 2.0.
Controversial information: Not production-ready.
Unique content: Modular design, support for various input/output sources, and processors.
https://github.com/chenquan/arkflow