Skip to content
核心场景
为三大场景深度优化
不是通用消息队列的简单堆叠，每个场景都经过专项设计
AI 训练加速
消灭 GPU 等待
- S3/MinIO 直连 + 三级缓存（内存/SSD/S3）
- 训练数据无需预导入，消除 I/O 瓶颈
- 百万级轻量 Topic，Agent 独立通道
IoT 全链路
边缘到云端统一
- MQTT 接入 / Kafka 消费，一套系统替代双架构
- 极小内存占用，支持边缘网关部署
- 断网缓存 + 自动同步，覆盖全链路
大数据管道
Kafka 协议兼容
- 完全兼容 Kafka 协议，现有应用零迁移
- 四模式存储引擎，Topic 级独立配置
- 冷数据自动分层到 S3，成本降低 95%
系统架构
三组件，极简边界
计算、存储、调度完全分离，每层独立扩展，单二进制交付
↔
集群协调
Broker
协议解析 · 消息路由 · 无状态
MQTT · Kafka · TCP/TLS/QUIC
↕
数据读写
Storage Engine
Memory · RocksDB · File Segment
ISR · Tiered Storage · S3
角色由配置决定
三个角色单二进制交付
存算彻底分离
核心特性
从内核开始设计
极致性能
Rust 构建，微秒延迟，无 GC 停顿，单节点百万级 QPS
双协议统一
MQTT 3.1/3.1.1/5.0 与 Kafka 完全兼容，统一存储层
插件化存储
Memory / RocksDB / File Segment / S3，Topic 级粒度配置
零外部依赖
单二进制，内置 Raft 共识，无需 ZooKeeper / etcd
存算分离
Broker 无状态水平扩展，存储独立演进，弹性自如
ISR 强一致
ISR 副本机制，Active/Sealed Segment 分层，无迁移扩容