Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
- batch-processing
- kafka
- pathway
- python
47,133 repositories indexed
1–24 of 33 · 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.
Fancy stream processing made operationally mundane
The live data layer for apps and AI agents. Create up-to-the-second views into your business, just using SQL
🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.
Ultra-high performance reactive programming
Kubernetes-native platform to run massively parallel data/streaming jobs
High-performance time-series aggregation for PostgreSQL
Project Flogo is an open source ecosystem of opinionated event-driven capabilities to simplify building efficient & modern serverless functions, microservices & edge apps.
Compositional, streaming I/O library for Scala
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.
Ruby and Rails efficient Kafka processing framework
A lightweight stream processing library for Go
Lightweight data stream processing engine for IoT edge
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.
🌊 Continuously synchronize the systems where your data lives, to the systems where you _want_ it to live, by managing your data flows with Estuary. 🌊
Esper Complex Event Processing, Streaming SQL and Event Series Analysis
Tenzir is the data pipeline engine for security teams.
Lightweight real-time big data streaming engine over Apache Pekko
Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.
HStreamDB is an open-source, cloud-native streaming database for IoT and beyond. Modernize your data stack for real-time applications.
🏎️ Streams & Reactive Programming paradigm for Go: declarative and composable API for event-driven applications