Building event-driven applications the easy way in Go.
- watermill
- event-driven
- event-sourcing
- sagas
47,133 repositories indexed
1–23 of 23 · Most stars
Building event-driven applications the easy way in Go.
Event streaming platform for agentic AI. Continuously ingest, transform, and serve event streams in real time, at scale.
Fancy stream processing made operationally mundane
Apache KIE (Knowledge Is Everything) is the home of Drools, OptaPlanner, jBPM, and Kogito.
Asynchronous Python framework for event-driven services. A thin client for Kafka, RabbitMQ, NATS, Redis and MQTT with full access to native broker features, plus AsyncAPI docs, in-memory tests and observability out of the box.
🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.
A network event stream processing system, in Clojure.
Project Flogo is an open source ecosystem of opinionated event-driven capabilities to simplify building efficient & modern serverless functions, microservices & edge apps.
Compositional, streaming I/O library for Scala
The fastest unified streaming SQL Engine in a single C++ binary. ⚡ Millisecond latency. 100+ GB/s throughput. Continuously compute stateful context from streams, logs, metrics, events, and CDC.
Ruby and Rails efficient Kafka processing framework
Stream Processing and Complex Event Processing Engine
Python Streaming DataFrames for Kafka
A platform that makes it easy for developers to build realtime, cost-effective, operations-focused applications
A compatibility layer for event-driven abstractions
Esper Complex Event Processing, Streaming SQL and Event Series Analysis
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
🏎️ Streams & Reactive Programming paradigm for Go: declarative and composable API for event-driven applications
.NET Stream Processing Library for Apache Kafka 🚀
The database purpose-built for stream processing applications.
Real-time decision features without streaming infra. Turn live events into product reflexes — no Kafka, no Flink, no feature store.
Small, Fast event processing and monitoring for Erlang/OTP applications.
Scramjet Platform is a distributed runtime supervisor that can run data processing programs called Sequences and manage local resources on any Linux server, Docker on small edge servers, and even large-scale Kubernetes clusters in the cloud or datacenters without exposing network ports to the public internet.