chenquan/arkflow: High-performance Rust stream processing engine, providing powerful data stream processing capabilities, supporting multiple input/output sources and processors.

ArkFlow is a high-performance stream processing engine built in Rust, utilizing the Tokio async runtime for low latency. It supports multiple input/output sources such as Kafka, MQTT, HTTP, and files, along with various data processors including SQL queries, JSON processing, and Protobuf encoding/decoding. The modular design makes it easily extensible with new components.