Install & Compatibility
Where this runs
tested against v3.24.0 · pip install
no network on importno background threads
Install × environment matrix
Each cell = how many times install + import succeeded across repeated harness runs. Partial = flaky.
glibc = Debian/Ubuntu slim · musl = Alpine Linux
muslpy 3.10–3.910 runs
build_error
glibcpy 3.10–3.910 runs
installs and imports cleanly · install 10.3s · import 1.955s · 112MB
113MB installed
● package 113MB
Code
Verified usage
Verified import paths — ran on the pinned version, not inferred.
Application
✓ from quixstreams import Application
✗ from quixstreams.app import Application
Application is a top-level export since v3.0
StreamingDataFrame
✓ from quixstreams import StreamingDataFrame
✗ from quixstreams.dataframe import StreamingDataFrame
Correct import is from quixstreams directly
Topic
✓ from quixstreams import Topic
✗ from quixstreams.topic import Topic
Topic is re-exported at package level
Minimal stream processing app that increments a counter for each message.
from quixstreams import Application
import os
app = Application(broker_address=os.environ.get('KAFKA_BROKER', 'localhost:9092'))
topic = app.topic('my-topic', value_deserializer='json')
@app.dataframe(topic)
def process(df):
df = df.apply(lambda row: {'count': row.get('count', 0) + 1})
return df
if __name__ == '__main__':
app.run()
quix --version
Errors
Common errors & fixes
ModuleNotFoundError: No module named 'confluent_kafka'
Missing Kafka C library or Python bindings.
fixInstall confluent-kafka: pip install quixstreams[kafka] or separately: pip install confluent-kafka
AttributeError: 'Application' object has no attribute 'run'
Using a very old version (<0.5) where the method was named differently.
fixUpgrade to latest: pip install --upgrade quixstreams
ValueError: Topic 'my-topic' does not exist and auto_create_topics is False
Kafka topic must be created beforehand or auto-creation must be enabled.
fixSet auto_create_topics=True in Application() or create the topic manually via Kafka admin.
TypeError: 'NoneType' object is not callable in StreamingDataFrame.apply()
The apply function returned None instead of a value.
fixEnsure your apply function returns a value (can be the input row modified).
Upgrade
Version history
3.24.0latest on PyPI · released Jun 12, 2026
Audit
Dependencies
confluent-kafkarequiredCore Kafka client dependency
quixstreamsoptionalOptional extras: app, connectors, etc.