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: about 10 hours 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
Related 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 |