Repository Index

Building event-driven applications the easy way in Go.

• watermill
• event-driven
• event-sourcing
• sagas

Fancy stream processing made operationally mundane

• message-queue
• stream-processing
• streaming-data
• message-bus

Distributed and fault-tolerant realtime computation: stream processing, continuous computation, distributed RPC, and more

Apache Beam is a unified programming model for Batch and Streaming data processing.

• python
• java
• big-data
• beam

Fast and Lightweight Logs, Metrics and Traces processor for Linux, BSD, OSX and Windows

• fluentd
• c
• logging
• data-collector

Apache KIE (Knowledge Is Everything) is the home of Drools, OptaPlanner, jBPM, and Kogito.

• rule-engine
• java
• dmn
• hacktoberfest

🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.

• cloud-native
• streaming
• rust
• real-time

Reactive Extensions for the Go language.

• reactivex
• golang
• observable
• go

Distributed stream processing engine in Rust

• data
• dev-tools
• infrastructure
• kafka

A network event stream processing system, in Clojure.

• riemann
• events
• clojure
• monitoring

Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.

• goka
• stream
• processing
• kafka

Project Flogo is an open source ecosystem of opinionated event-driven capabilities to simplify building efficient & modern serverless functions, microservices & edge apps.

• flogo
• iot
• integration
• golang

YTsaurus is a scalable and fault-tolerant open-source big data platform.

• big-data
• clickhouse
• distributed-database
• lakehouse

Distributed Stream Processing

• stream-processing
• stream-processor
• stream-processing-engine
• pony-language

tools for working with streams of data

A compatibility layer for event-driven abstractions

• stream-processing
• future
• clojure
• async

🌊 Continuously synchronize the systems where your data lives, to the systems where you _want_ it to live, by managing your data flows with Estuary. 🌊

• change-data-capture
• data
• data-collection
• data-engineering

Build platforms that flexibly mix SQL, batch, and stream processing paradigms

• golang
• event-sourcing
• stream-processing
• brokers

Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.

• iot
• analytics
• edge
• stream-processing

Low-code tool for automating actions on real time data | Stream processing for the users.

• flink
• flink-kafka
• apache-flink
• gui

🏎️ Streams & Reactive Programming paradigm for Go: declarative and composable API for event-driven applications

• event-driven
• generics
• go
• golang

A lightweight Reactive Streams Infrastructure Toolkit for Scala.

Machine is a workflow/pipeline library for processing data

• golang
• golang-library
• golang-package
• workflow

Small, Fast event processing and monitoring for Erlang/OTP applications.