Open source. Open possibilities.

Go library offering bounded Apache Kafka producer, consumer, replay, inspection and transactional building blocks that wrap franz-go without hiding delivery outcomes, lifecycle ownership or topic policy.

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

A runnable local real-time analytics pipeline using Kafka-compatible broker (Redpanda) and PySpark Structured Streaming. Simulates clickstream events, performs windowed aggregation with watermarking, all via docker-compose.

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.

KEFCore is an Entity Framework Core provider for Apache Kafka, enabling .NET applications to use Kafka topics as a distributed database. It offers full LINQ support and allows interaction with Kafka through standard EF Core models, abstracting away Kafka-specific client code.

Apache Kafka is an open-source distributed event streaming platform designed for high-performance data pipelines, streaming analytics, and data integration.

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.