Repository Index

The Reactive Extensions for .NET

Asynchronous Python framework for event-driven services. A thin client for Kafka, RabbitMQ, NATS, Redis and MQTT with full access to native broker features, plus AsyncAPI docs, in-memory tests and observability out of the box.

• asyncio
• kafka
• python
• rabbitmq

Concurrent and multi-stage data ingestion and data processing with Elixir

• elixir
• genstage
• data-ingestion
• data-processing

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

Python Stream Processing

• python
• stream-processing
• rust
• data-engineering

Stream Processing and Complex Event Processing Engine

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

Python Streaming DataFrames for Kafka

• kafka
• python
• stream-processing
• data-engineering

Distributed Stream Processing

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

A platform that makes it easy for developers to build realtime, cost-effective, operations-focused applications

Esper Complex Event Processing, Streaming SQL and Event Series Analysis

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

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

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

• event-driven
• generics
• go
• golang

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

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

Reactive Extensions for Elixir

Reactive queryable observable framework.

• reactive
• rx
• qbservable
• observable

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

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

Experiments in Streaming

Parallelize _anything_ //

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

Create a data stream across your information systems to query, augment and transform data according to Elixir matching rules.