Bytewax: Stream processing library built using Python and Rust
Bytewax is now community-maintained. As of May 2025, Bytewax (the company) is no longer commercially viable and the original core team has stepped back from day-to-day maintenance. The project remains open source under Apache-2.0 and we are actively rebuilding the maintainer pool. If you depend on Bytewax in production, or want to help maintain it, please weigh in on #560 or read MAINTAINERS.md for how to get involved.
Bytewax is a Python framework and Rust-based distributed processing engine for stateful event and stream processing. Inspired by capabilities found in tools like Apache Flink, Spark, and Kafka Streams, Bytewax makes stream processing simpler and more accessible by integrating directly with the Python ecosystem you already know and trust.
Install waxctl to manage deployments at scale.
Bytewax uses a dataflow computational model , similar to systems like Flink or Spark, but with a Pythonic interface. You define a dataflow graph of operators and connectors:
Stateful operations: Bytewax maintains distributed state, allows for fault tolerance and state recovery, and supports event-time windowing for advanced analytics and machine learning workloads.
waxctl : Bytewax’s CLI tool for deploying and managing dataflows on cloud servers or Kubernetes clusters. Download waxctl here .