ArkFlow:高性能Rust流处理引擎

2025-04-29
ArkFlow:高性能Rust流处理引擎

ArkFlow是一个基于Rust和Tokio构建的高性能流处理引擎,支持多种输入/输出源和处理器。它具有强大的数据流处理能力,内置SQL查询、JSON处理、Protobuf编码/解码等功能,并支持扩展。用户可通过YAML配置文件轻松配置输入源(Kafka、MQTT、HTTP、文件等)、处理器(JSON、SQL、Protobuf等)和输出目标(Kafka、MQTT、HTTP、标准输出等),实现灵活的数据处理流程。ArkFlow还提供缓冲机制以应对反压,并支持多种错误输出目标。

开发