Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
- batch-processing
- kafka
- pathway
- python
47,133 repositories indexed
1–18 of 18 · Most stars
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Event streaming platform for agentic AI. Continuously ingest, transform, and serve event streams in real time, at scale.
Hazelcast is a unified real-time data platform combining stream processing with a fast data store, allowing customers to act instantly on data-in-motion for real-time insights.
🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.
StreamAlert is a serverless, realtime data analysis framework which empowers you to ingest, analyze, and alert on data from any environment, using datasources and alerting logic you define.
High-performance time-series aggregation for PostgreSQL
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.
Python Streaming DataFrames for Kafka
A platform that makes it easy for developers to build realtime, cost-effective, operations-focused applications
High performance Rust stream processing engine seamlessly integrates AI capabilities, providing powerful real-time data processing and intelligent analysis.
Real-time stream processing for python
Lightweight real-time big data streaming engine over Apache Pekko
Low-code tool for automating actions on real time data | Stream processing for the users.
HStreamDB is an open-source, cloud-native streaming database for IoT and beyond. Modernize your data stack for real-time applications.
Series and Panels for Real-time and Exploratory Analysis of Data Streams
The database purpose-built for stream processing applications.
Amazon Kinesis Aggregators provides a simple way to create real time aggregations of data on Amazon Kinesis.
Real-time decision features without streaming infra. Turn live events into product reflexes — no Kafka, no Flink, no feature store.