Repository Index

Fancy stream processing made operationally mundane

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

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

Canonical actor model implementation for .NET with local + distributed actors in C# and F#.

• akka
• actor-model
• dotnet
• concurrency

A network event stream processing system, in Clojure.

• riemann
• events
• clojure
• monitoring

Ultra-high performance reactive programming

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.

• security
• kinesis
• serverless
• terraform

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

Compositional, streaming I/O library for Scala

• scala
• stream
• streaming-computation
• fp

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.

• clickhouse
• sql
• redpanda
• single-binary

👜 Tiny and fast reactive/iterable programming library

• callbacks
• reactive
• iterables
• observables

Probabilistic data structures for processing continuous, unbounded streams.

• bloom-filter
• go
• stable-bloom-filters
• cuckoo-filter

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

• event-driven
• generics
• go
• golang

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.

• nodejs
• stream-processing
• transform-as-a-service
• real-time

Stream Processing Made Easy

• machine-learning
• reactive-programming
• kafka
• reactive-systems

Simple yet powerful live data computation framework.

• react
• javascript
• typescript
• event-stream

Simple yet powerful live data computation framework. C++ port of Scramjet framework.

• event-stream
• reactive-programming
• stream
• data-stream