Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.

Python Stream Processing

🌊 Online machine learning in Python

FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.

Python clone of Spark, a MapReduce alike framework in Python

Python Stream Processing

A Python stream processing engine modeled after Yahoo! Pipes

Python Streaming DataFrames for Kafka

Play any radios around the globe right from the terminal ⚡

csp is a high performance reactive stream processing library, written in C++ and Python

Distributed event processing for Python based on Redis Streams

⚡A supercharged, interactive Kafka shell built on top of the existing Kafka CLI tools.

An open source, cloud-native streaming data integration and analytics product optimized for agile digital businesses

Toolkit for graph-relational data across space and time

A stream processing runtime that allows connecting any streaming data source to any destination and act on it

Elkeid HUB is a rule/event processing engine maintained by the Elkeid Team that supports streaming/offline (not yet supported by the community edition) data processing. The original intention is to solve complex data/event processing and external system linkage requirements through standardized rules.

🚨 Simple, self-contained fraud detection system built with Apache Kafka and Python

Streaming Ethereum and Bitcoin blockchain data to Google Pub/Sub or Postgres in Kubernetes

Project for real-time anomaly detection using Kafka and python

Stream processing using kafka-python to track people (user input images of target) in the wild over multiple video streams.