Código abierto. Nuevas posibilidades.

Watermill es una biblioteca de Go para construir aplicaciones dirigidas por eventos con flujos de mensajes. Ofrece una interfaz simple para mensajería pub/sub, compatible con Kafka, RabbitMQ, NATS, Redis, SQL y más.

KEFCore es un proveedor de Entity Framework Core para Apache Kafka que permite a las aplicaciones .NET usar temas de Kafka como base de datos distribuida, con soporte completo para LINQ e integración transparente con el modelo estándar de EF Core.

Apache Kafka es una plataforma de streaming de eventos distribuida de código abierto diseñada para pipelines de datos de alto rendimiento, analítica de streaming e integración de datos.

Pathway es un framework ETL de Python para procesamiento de flujos, análisis en tiempo real y pipelines de IA que incluyen aplicaciones LLM y RAG. Ejecuta código Python en un motor Rust para computación incremental, admite datos por lotes y en flujo con el mismo código y se despliega mediante Docker y Kubernetes.

go-kafka es un módulo de Go bajo licencia MIT que proporciona bloques de construcción acotados y explícitos para productores, consumidores, reproducciones, inspecciones y transacciones de Apache Kafka, envuelto alrededor de franz-go.

RisingWave es una plataforma de streaming de eventos diseñada para IA agéntica que integra la ingesta, el procesamiento y el servicio de datos en un único sistema.

Pipeline de análisis en tiempo real en Docker que usa Redpanda como broker compatible con Kafka y PySpark Structured Streaming. Simula eventos clickstream, aplica agregación con ventanas y watermarking.