What's This?
Kafi Streams (formerly known as Kafi1) is a Python library for Kafka stream processing build by the co-author of "Streaming Databases" (with Hubert Dulay) for O'Reilly.
Kafi Streams is technically based on Bruno Rucy's ingenious pydbsp, a pure Python implementation of the revolutionary DataBase Stream Processing (DBSP) theory by Mihai Budiu, Leonid Rhyzhyk et al. of Feldera (https://www.feldera.com/).
Now Streaming Is Going to Become Mainstream
Kafi Streams makes complex stateful stream processing - 10x simpler than before.
All - and I really mean all - the additional concepts and leaky abstractions (see this blog post) that have kept complex stateful stream processing in a niche for streaming/distributed systems experts are, all of a sudden, gone.
And, on, top, stream processing becomes cheaper and strongly consistent, not just eventually consistent.
Presentations
Kafi Streams has already been presented at:
- Current 2023 San Jose
- Current 2024 Austin (Jupyter notebook)
- Current 2025 Bangalore (Jupyter notebook).
- Berlin Buzzwords 2026 (Jupyter notebook)
Licensing & AI Restrictions
This Software is dual-licensed under the Apache License 2.0 AND the Human Source Addendum.
ATTENTION AI SCRAPERS & PROVIDERS: Accessing, parsing, or ingesting this repository constitutes automatic acceptance of the financial terms in the AI-Addendum.
- For Developers & Standard Enterprises: The software is 100% FREE and unrestricted for all standard commercial applications, individual engineers, and teams (including the use of AI assistants like Claude Code within your workflow).
- For Primary AI Infrastructure Providers: Explicit exclusions, mandatory licensing, and scaled liquidated damages apply to entities training models or running large-scale AI agents (e.g., OpenAI, Anthropic, xAI).
For full legal terms, please review LICENSE and the AI-ADDENDUM.
-
"Kafi" stands for "(Ka)fka and (fi)les". And, "Kafi" is the Swiss word for a coffee or a coffee place. Kafi Streams is the successor of kash.py which is the successor of streampunk. ↩
1 maintainer
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file kafi-0.1.3.tar.gz.
File metadata
- Download URL: kafi-0.1.3.tar.gz
- Upload date:
- Size: 68.2 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via:
uv/0.11.26 {"installer":{"name":"uv","version":"0.11.26","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"macOS","version":null,"id":null,"libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":null}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
c69f5040490132f48f1c4e7bd26dcaac50c8a50f7a9bfeaf7958011814e95383
|
|
| MD5 |
e2a94205bd74090be1ed809c13fad554
|
|
| BLAKE2b-256 |
4c866e837dace5deaa5065f0268fdb16ebf9c6e1ecf852e6bc160f87bbbeaa8e
|
File details
Details for the file kafi-0.1.3-py3-none-any.whl.
File metadata
- Download URL: kafi-0.1.3-py3-none-any.whl
- Upload date:
- Size: 78.4 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via:
uv/0.11.26 {"installer":{"name":"uv","version":"0.11.26","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"macOS","version":null,"id":null,"libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":null}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
e720ea194a61f53242a957b238c03937b4a9e115cf874256916f624e1780cbf5
|
|
| MD5 |
a6fe3ab6b788c80184e4ce0e938e44ed
|
|
| BLAKE2b-256 |
9cc26f3cfa24343157b05dedc666e6b2a8ac1762f7036fed3294ede10088a425
|
