risingwave

RisingWave es una plataforma de streaming de eventos que reemplaza los stacks complejos tradicionales (como Debezium, Kafka y Flink) al unificar la ingesta de datos, el procesamiento incremental y el servicio de baja latencia. Está diseñada para proporcionar datos frescos y consultables para aplicaciones en tiempo real y agentes de IA. Las capacidades clave incluyen: - **Ingesta multi-fuente**: Soporta webhooks, CDC nativo desde bases de datos (PostgreSQL, MySQL), flujos de eventos (Kafka, Pulsar, Kinesis) y datos históricos por lotes desde S3. - **Procesamiento incremental**: Utiliza vistas materializadas para realizar computaciones continuas, asegurando una frescura de datos de extremo a extremo inferior a 100 ms. - **Servicio de baja latencia**: Mantiene los resultados en un almacenamiento de filas interno para atender consultas SQL con una latencia p99 de 10-20 ms. - **Integración de almacenamiento abierto**: Escribe en tablas de Apache Iceberg para retención a largo plazo y acceso analítico, utilizando Apache DataFusion para la ejecución de consultas vectorizadas. - **Arquitectura eficiente en costos**: Almacena el estado interno y las vistas materializadas en almacenamiento de objetos (S3) para reducir costos y permitir el escalado elástico, con una caché de disco opcional para el rendimiento. - **Compatibilidad**: Se conecta a través del protocolo de cable de PostgreSQL y proporciona un servidor MCP, CLI y Skills para la integración de agentes de IA. Los casos de uso comunes incluyen el monitoreo y alerta en tiempo real, feature stores para ML, tableros en vivo, enriquecimiento de datos en tiempo real y streaming lakehouses.