#stream-processing

Event streaming platform for agentic AI. Continuously ingest, transform, and serve event streams in real time, at scale.

Asynchronous Python framework for event-driven services. A thin client for Kafka, RabbitMQ, NATS, Redis and MQTT with full access to native broker features, plus AsyncAPI docs, in-memory tests and observability out of the box.

The live data layer for apps and AI agents. Create up-to-the-second views into your business, just using SQL

A high-performance observability data pipeline.

Fast and Lightweight Logs, Metrics and Traces processor for Linux, BSD, OSX and Windows

Kubernetes-native platform to run massively parallel data/streaming jobs

🌊 Online machine learning in Python

Python Streaming DataFrames for Kafka

Fancy stream processing made operationally mundane

Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage

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

A library to build streaming applications that consume from and produce to Kafka.

QuestDB is a high performance, open-source, time-series database