go-streams

轻量级 Go 流处理库，用声明式 DSL 以 Source/Flow/Sink 组合数据管道，内置映射、过滤、窗口、节流等算子及 Kafka、Redis、WebSocket 等连接器。