高性能Rust流处理引擎，无缝集成AI能力，提供强大的实时数据处理与智能分析。 它不仅支持多种输入/输出源和处理器，更能轻松加载和执行机器学习模型，实现流式数据和推理、异常检测和复杂事件处理。 
特性

高性能：基于Rust和Tokio异步运行时构建，提供卓越的性能和低延迟
智能分析：无缝集成AI模型，提供强大的智能分析功能
多种数据源：支持Kafka、MQTT、HTTP、文件等多种输入输出源
强大的处理能力：内置SQL查询、Python脚本、JSON处理、Protobuf编解码、批处理等多种处理器
可扩展：模块化设计，易于扩展新的输入、缓冲区、输出和处理器组件