Building event-driven applications the easy way in Go.
- watermill
- event-driven
- event-sourcing
- sagas
73,362 visible repositories in the index
1–24 of 39 · 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
Fast and Lightweight Logs, Metrics and Traces processor for Linux, BSD, OSX and Windows
The live data layer for apps and AI agents. Create up-to-the-second views into your business, just using SQL
🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.
Canonical actor model implementation for .NET with local + distributed actors in C# and F#.
A network event stream processing system, in Clojure.
A modular implementation of timely dataflow in Rust
Drop-in Apache Spark replacement written in Rust, unifying batch processing, stream processing, and compute-intensive AI workloads.
An implementation of differential dataflow using timely dataflow on Rust.
StreamAlert is a serverless, realtime data analysis framework which empowers you to ingest, analyze, and alert on data from any environment, using datasources and alerting logic you define.
Concurrent and multi-stage data ingestion and data processing with Elixir
Project Flogo is an open source ecosystem of opinionated event-driven capabilities to simplify building efficient & modern serverless functions, microservices & edge apps.
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
Fancy stream processing made operationally mundane. This repository is a fork of the original project before the license was changed.
The Feldera Incremental Computation Engine
Stream Processing and Complex Event Processing Engine
Python Streaming DataFrames for Kafka
High performance Rust stream processing engine seamlessly integrates AI capabilities, providing powerful real-time data processing and intelligent analysis.
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