risingwave

RisingWave 是一个事件流平台，通过统一数据摄取、增量处理和低延迟服务，取代了传统的复杂技术栈（如 Debezium、Kafka 和 Flink）。它旨在为实时应用和 AI Agent 提供新鲜且可查询的数据。 核心能力包括： - **多源摄取**：支持 Webhooks、数据库原生 CDC（PostgreSQL, MySQL）、事件流（Kafka, Pulsar, Kinesis）以及来自 S3 的历史批处理数据。 - **增量处理**：利用物化视图进行持续计算，确保端到端数据新鲜度在 100 毫秒以内。 - **低延迟服务**：将结果维护在内部行存储中，以 10-20 毫秒的 p99 延迟响应 SQL 查询。 - **开放存储集成**：将数据写入 Apache Iceberg 表以进行长期保留和分析访问，并利用 Apache DataFusion 实现向量化查询执行。 - **高成本效益架构**：将内部状态和物化视图存储在对象存储（S3）中，以降低成本并实现弹性扩展，同时提供可选的磁盘缓存以提升性能。 - **兼容性**：通过 PostgreSQL 线缆协议连接，并提供 MCP 服务器、CLI 以及用于 AI Agent 集成的 Skills。 常见用例包括实时监控与告警、机器学习特征存储、实时仪表盘、实时数据富化以及流式湖仓（Streaming Lakehouses）。