---
id: quixstreams
version: "3.25.0"
license: Apache License Version 2.0, January 2004 http://www.apache.org/licenses/ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION 1. Definitions. "License" shall mean the terms and conditions for… (full text in the JSON record)
license_treatment: permissive
maintenance: active
---

# quixstreams — Python library for building stream processing applications with Apache Kafka

License: permissive · Maintenance: active · Downloads: 86.3K/mo

## What it is and what it does

Quix Streams is a Python library for building stream processing applications that consume, transform, and produce data on Apache Kafka topics. It provides a declarative DataFrame-like API for defining data pipelines, with support for windowing, joins, branching, and group-by operations. The framework handles Kafka's consumer groups, message deserialization, state management, and exactly-once processing semantics automatically, letting you focus on transformation logic rather than infrastructure.

The library depends on confluent-kafka for Kafka protocol support, pydantic for configuration validation, orjson and jsonschema for serialization, and rocksdict for fault-tolerant state storage. It runs anywhere Python is installed and can be deployed to your own infrastructure or to Quix Cloud for managed hosting. The framework is designed for both simple producer-consumer applications and complex event-driven systems, real-time analytics, and machine learning pipelines.

Use it for:

- Build real-time alerting systems that consume sensor or application data from Kafka, filter or aggregate it, and produce alerts to downstream topics.
- Process time-series data with windowing and stateful operations to compute rolling metrics, anomaly detection, or trend analysis.
- Create event-driven microservice architectures where services consume domain events, apply business logic, and emit new events for other services.
- Enrich incoming data streams by joining them with reference data or state, then produce enriched records to output topics.
- Implement exactly-once data pipelines that transform and load data from Kafka into data warehouses or analytics systems without duplication.

## Worth the install?

AI-flagged interpretation of the facts above — verify before relying.

Quix Streams is a Python framework for building stream processing applications on Apache Kafka, enabling real-time data transformation, stateful operations, and event-driven microservices without managing server-side clusters.

Yes. Quix Streams is a production-ready, actively maintained framework with low install friction, permissive licensing, and no known vulnerabilities. Install it if you need to build Kafka-based stream processing applications in Python without managing a separate cluster—it handles state, exactly-once semantics, and common operations out of the box. The 11 dependencies are well-established libraries (confluent-kafka, pydantic, orjson, rocksdict) that are widely used and stable.

## Install

pip install quixstreams
uv add quixstreams
poetry add quixstreams

## Installing quixstreams

Before you install: Low install friction with a pure-Python wheel and 11 runtime dependencies. Active maintenance with a release 21 days ago and ongoing commits; the project has 1567 GitHub stars and reached production stability.

License in practice: Licensed under Apache 2.0 (permissive), allowing commercial use, modification, and distribution with minimal restrictions—you must include a copy of the license and note any changes you make.

Quickstart:

pip install quixstreams

from quixstreams import Application

app = Application(broker_address="localhost:9092")
topic = app.topic("input-topic", value_deserializer="json")
sdf = app.dataframe(topic=topic)
sdf = sdf.apply(lambda value: {"processed": value})
app.run()

Requires Python 3.9 or later and Apache Kafka 0.10 or later accessible at the broker address.

Verify before relying:

- Performance characteristics and throughput limits under typical production workloads.
- Specific recovery and failover behavior during broker outages or network partitions.
- Memory footprint and state management overhead for large stateful operations.

## Package facts

- License: Apache License Version 2.0, January 2004 http://www.apache.org/licenses/ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION 1. Definitions. "License" shall mean the terms and conditions for… (full text in the JSON record) (permissive)
- Python support: supports_current
- Install friction: low
- Maintenance: active
- Downloads: 86.3K/month (top 15,000 on PyPI)
- Known vulnerabilities: none known

## Tags

kafka stream processing python, real-time data pipeline framework, event-driven microservices kafka, streaming dataframe api, kafka consumer producer python, stateful stream processing, kafka data transformation, kafka-streaming, event-driven, real-time-processing

[View on SkillFed](https://skillfed.io/packages/quixstreams) · [View on PyPI](https://pypi.org/project/quixstreams/)