Repository Index

Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.

• batch-processing
• kafka
• pathway
• python

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

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

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

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
• kakfa
• sql
• redpanda

Lightweight data stream processing engine for IoT edge

• edge
• sql
• iot
• edge-analytics

Probabilistic data structures for processing continuous, unbounded streams.

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

Stream Processing and Complex Event Processing Engine

• streaming-data-processing
• cep
• stream-processing
• complex-event-processing

A compatibility layer for event-driven abstractions

• stream-processing
• future
• clojure
• async

Esper Complex Event Processing, Streaming SQL and Event Series Analysis

• cep
• complex-event-processing
• open-source
• compiler

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

Compositional pipelines

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

Multi-core Window-Based Stream Processing Engine

• llvm
• incremental-computation
• aggregation
• stream-processing

Lightweight SQL-based stream processing engine for IoT edge.

• edge-analytics
• edge-computing
• iot
• sql

Parallelize _anything_ //

• ocaml-library
• parallel-computing
• stream-processing
• multi-processing

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