Open source. Open possibilities.

Watermill is a Go library for building event-driven applications with message streams. It provides a simple interface for pub/sub messaging, supporting Kafka, RabbitMQ, NATS, Redis, SQL, and more.

Pathway is a Python ETL framework for stream processing, real-time analytics, and AI pipelines including LLM and RAG applications. It runs Python code on a Rust engine for incremental computation, supports batch and streaming data with the same code, and deploys via Docker and Kubernetes.

A fully serverless, event-driven clickstream data pipeline on AWS that ingests, transforms, and stores clickstream events in Parquet format using API Gateway, Kinesis, Firehose, Lambda, and Athena, with production-ready IaC via AWS SAM.

MediaPipe is Google's cross-platform framework and suite of on-device machine learning solutions for live and streaming media, covering vision, text and audio tasks on Android, iOS, web, desktop and edge devices.

RisingWave is an event streaming platform designed for agentic AI that integrates ingestion, processing, and serving into a single system.

Vector is an open-source observability data pipeline written in Rust. It collects, transforms and routes logs and metrics as either an agent or an aggregator, letting teams control where telemetry goes and reduce vendor costs.