ArkFlow English | 中文 High-performance Rust stream processing engine, providing powerful data stream processing capabilities, supporting multiple input/output sources and processors. Features 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 proces...