makinage
Stream processor
Stream Processing Library and Framework
Stream Processing Made Easy
38 stars
4 watching
1 forks
Language: Python
last commit: almost 3 years ago
Linked from 1 awesome list
distributed-systemskafkamachine-learningpythonreactive-machine-learningreactive-programmingreactive-systemsstream-processingstreamingstreaming-data
manuzhang/awesome-streamingRelated projects:
| Repository | Description | Stars |
|---|---|---|
 nerevu/riko | A Python library for analyzing and processing streams of structured data | 1,605 |
 wintoncode/winton-kafka-streams | A Python implementation of Apache Kafka's Streams API for building stream processing applications | 311 |
 wallaroolabs/wally | A distributed stream processing framework for real-time data reactions | 1,477 |
 bytewax/bytewax | A Python framework for stateful stream and event processing with built-in connectors and flexible dataflow capabilities. | 1,585 |
 reugn/go-streams | Provides a lightweight and flexible way to process data streams in Go | 1,935 |
 apache/rocketmq-streams | Provides a lightweight stream processing framework | 172 |
 nodefluent/kafka-streams | A Node.js library implementing Kafka Streams functionality for stream state processing and table representation. | 831 |
 quixio/quix-streams | A Python framework for real-time data processing on Apache Kafka streams | 1,246 |
 keilerkonzept/topk | An implementation of probabilistic data structures for approximate data stream processing | 4 |
 jpcik/morph-streams | A tool for processing and analyzing continuous data streams using query languages | 16 |
 leepike/copilot | A language and toolset for generating hard real-time C code from a domain-specific stream language | 149 |
 bkirwi/coast | A streaming data processing framework with strong ordering and exactly-once semantics | 60 |
 python-streamz/streamz | A library for building and managing real-time stream processing pipelines in Python | 1,247 |
 picanumber/yapp | Parallel pipeline library for stream processing | 62 |
 gojek/ziggurat | A framework for building stateless applications on top of Kafka stream processing | 399 |