wally

bytewax/bytewax1.6K

Stream processor

A Python framework for stateful stream and event processing with built-in connectors and flexible dataflow capabilities.

reugn/go-streams1.9K

Stream processor library

Provides a lightweight and flexible way to process data streams in Go

python-streamz/streamz1.2K

Stream processor

A library for building and managing real-time stream processing pipelines in Python

maki-nage/makinage38

Stream processor

Stream Processing Library and Framework

olacabs/fabric55

Stream processor

A real-time stream processing framework designed to handle high-volume event ingestion and complex data processing tasks with guaranteed availability and scalability.

nerevu/riko1.6K

Stream processor

A Python library for analyzing and processing streams of structured data

bkirwi/coast60

Stream processor

A streaming data processing framework with strong ordering and exactly-once semantics

picanumber/yapp62

Pipeline library

Parallel pipeline library for stream processing

substantic/rain749

Pipeline processor

A framework for processing large-scale task-based pipelines in a distributed manner

quixio/quix-streams1.2K

Data processor

A Python framework for real-time data processing on Apache Kafka streams

go-playground/webhooks963

Notification processor

A library that enables easy processing of GitHub, Bitbucket, GitLab, and other web service notifications.

scramjetorg/framework-cpp3

Stream processor

A C++ framework for reactive stream programming with concurrent asynchronous operations

keilerkonzept/topk4

Stream processor

An implementation of probabilistic data structures for approximate data stream processing

scramjetorg/framework-python35

Stream processor

Reactive stream processing framework for Python

gazette/core723

Streaming platform

Enables teams to build platforms mixing SQL, batch, and real-time streaming processing paradigms