{"library":"quixstreams","title":"Quix Streams","description":"Quix Streams is a Python library for building stream processing applications with Apache Kafka. Version 3.23.6 supports stateful operations, windowing, connectors, and Quix Cloud integration. Requires Python >=3.9, <4. Release cadence is active with frequent minor releases.","language":"python","status":"active","last_verified":"Fri May 01","install":{"commands":["pip install quixstreams","pip install quixstreams[kafka]"],"cli":{"name":"quix","version":"sh: 1: quix: not found"}},"imports":["from quixstreams import Application","from quixstreams import StreamingDataFrame","from quixstreams import Topic"],"auth":{"required":false,"env_vars":[]},"quickstart":{"code":"from quixstreams import Application\nimport os\n\napp = Application(broker_address=os.environ.get('KAFKA_BROKER', 'localhost:9092'))\ntopic = app.topic('my-topic', value_deserializer='json')\n\n@app.dataframe(topic)\ndef process(df):\n    df = df.apply(lambda row: {'count': row.get('count', 0) + 1})\n    return df\n\nif __name__ == '__main__':\n    app.run()","lang":"python","description":"Minimal stream processing app that increments a counter for each message.","tag":null,"tag_description":null,"last_tested":null,"results":[]},"compatibility":null}