quix-streams
Data processor
A Python framework for real-time data processing on Apache Kafka streams
Python stream processing for Kafka
1k stars
19 watching
70 forks
Language: Python
last commit: 3 months ago
Linked from 1 awesome list
data-engineeringdata-intensive-applicationsdata-scienceevent-driven-architecturekafkamachine-learningpythonreal-time-data-processingstream-processingstream-processorstreaming-datastreaming-data-pipelinesstreaming-data-processingtime-series-data
manuzhang/awesome-streamingRelated projects:
| Repository | Description | Stars |
|---|---|---|
 wintoncode/winton-kafka-streams | A Python implementation of Apache Kafka's Streams API for building stream processing applications | 311 |
 bytewax/bytewax | A Python framework for stateful stream and event processing with built-in connectors and flexible dataflow capabilities. | 1,585 |
 nodefluent/kafka-streams | A Node.js library implementing Kafka Streams functionality for stream state processing and table representation. | 831 |
 turbolytics/sql-flow | An open-source tool that enables writing Kafka stream processing logic using standard SQL syntax. | 73 |
 confluentinc/ksql | A database for real-time stream processing applications built on top of Apache Kafka. | 133 |
 streamthoughts/kafka-connect-file-pulse | A tool that enables streaming and processing of various file formats into Apache Kafka | 324 |
 wallaroolabs/wally | A distributed stream processing framework for real-time data reactions | 1,477 |
 reugn/go-streams | Provides a lightweight and flexible way to process data streams in Go | 1,935 |
 ibmstreams/streamsx.kafka | A toolkit for integrating Apache Kafka with Stream Processor SPL applications | 13 |
 maki-nage/makinage | Stream Processing Library and Framework | 38 |
 nerevu/riko | A Python library for analyzing and processing streams of structured data | 1,605 |
 faust-streaming/faust | A Python stream processing library that enables real-time data pipelines and event-driven systems with scalability and reliability. | 1,675 |
 apache/rocketmq-streams | Provides a lightweight stream processing framework | 172 |
 bkirwi/coast | A streaming data processing framework with strong ordering and exactly-once semantics | 60 |
 pystorm/streamparse | Enables real-time computation on live streams of data using Python | 1,494 |