risingwave

RisingWave é uma plataforma de streaming de eventos que substitui stacks complexas tradicionais (como Debezium, Kafka e Flink) ao unificar a ingestão de dados, o processamento incremental e o serviço de baixa latência. Ela foi projetada para fornecer dados atualizados e consultáveis para aplicações em tempo real e agentes de IA. As principais capacidades incluem: - **Ingestão Multi-fonte**: Suporta webhooks, CDC nativo de bancos de dados (PostgreSQL, MySQL), fluxos de eventos (Kafka, Pulsar, Kinesis) e dados históricos em lote do S3. - **Processamento Incremental**: Utiliza materialized views para realizar computação contínua, garantindo a atualização de dados de ponta a ponta em menos de 100ms. - **Serviço de Baixa Latência**: Mantém os resultados em um row store interno para atender consultas SQL com latência p99 de 10-20 ms. - **Integração de Armazenamento Aberto**: Grava em tabelas Apache Iceberg para retenção de longo prazo e acesso analítico, utilizando Apache DataFusion para execução de consultas vetorizadas. - **Arquitetura de Custo Eficiente**: Armazena o estado interno e materialized views em armazenamento de objetos (S3) para reduzir custos e permitir escalonamento elástico, com um cache de disco opcional para desempenho. - **Compatibilidade**: Conecta-se via protocolo de rede PostgreSQL e fornece um servidor MCP, CLI e Skills para integração de agentes de IA. Casos de uso comuns incluem monitoramento e alerta em tempo real, feature stores para ML, dashboards ao vivo, enriquecimento de dados em tempo real e streaming lakehouses.