streamling

Streamling 是一个面向高性能、强一致性与可扩展性的列式数据流运行时。它基于 Apache Arrow 和 DataFusion 构建，支持以 Rust 或 WASM 编写插件，统一将所有组件（源、转换、汇）建模为 DataFusion 操作符，处理 RecordBatch 并提供端到端的至少一次交付、背压控制、检查点协调、模式校验及 upsert 语义保障。内置 Kafka、Postgres、ClickHouse 等连接器，适合构建需自定义逻辑、跨管道复用插件、并严格保证数据一致性的实时 ETL 流水线与变更数据捕获（CDC）场景。