Repository Index

Apache Storm

• storm
• apache
• distributed
• streaming

Hazelcast is a unified real-time data platform combining stream processing with a fast data store, allowing customers to act instantly on data-in-motion for real-time insights.

• java
• hazelcast
• in-memory
• big-data

The live data layer for apps and AI agents. Create up-to-the-second views into your business, just using SQL

• rust
• database
• sql
• streaming

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

• rule-engine
• java
• dmn
• hacktoberfest

A network event stream processing system, in Clojure.

• riemann
• events
• clojure
• monitoring

Ruby and Rails efficient Kafka processing framework

• karafka-framework
• kafka
• kafka-client
• kafka-clients

Conduit streams data between data stores. Kafka Connect replacement. No JVM required.

• go
• data-integration
• etl
• data-pipeline

Series and Panels for Real-time and Exploratory Analysis of Data Streams

• time-series
• real-time
• data-stream
• series-manipulation

The database purpose-built for stream processing applications.

• stream-processing
• real-time
• sql
• interactive

A streaming / online query processing / analytics engine based on Apache Storm

Mirror of Apache Samoa (Incubating)

• samoa

Amazon Kinesis Aggregators provides a simple way to create real time aggregations of data on Amazon Kinesis.

Real-time decision features without streaming infra. Turn live events into product reflexes — no Kafka, no Flink, no feature store.

• analytics
• feature-store
• fraud-detection
• python

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

Haskell distributed stream processing with exactly-once semantics

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

Open-source streaming SQL engine written in Rust using Apache Arrow and DataFusion. Supports continuous queries, temporal stream joins, tumbling/session windows, and CDC/Kafka connectors. Lightweight, embeddable, and sub-microsecond latency

Simple yet powerful live data computation framework.

• react
• javascript
• typescript
• event-stream

Python port of Scramjet framework

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

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