ArkFlow:高性能Rust流处理引擎

2025-03-14
ArkFlow:高性能Rust流处理引擎

ArkFlow是一个基于Rust和Tokio构建的高性能流处理引擎,支持Kafka、MQTT、HTTP等多种数据源和处理器,例如SQL查询、JSON处理和Protobuf编解码。它具有模块化设计,易于扩展,并通过YAML配置文件进行配置。用户可以轻松定义输入、处理管道和输出,实现各种数据流处理任务,例如Kafka到Kafka的数据处理或生成测试数据并进行处理。

开发