Bytewax
Bytewax is a Python-native distributed stream processing framework built on a Rust runtime. Developers define dataflows using the bytewax.dataflow API, composing operators (map, filter, reduce, joins, windowing) over connectors for Kafka, files, stdio, demos, and custom sources/sinks. The Bytewax Platform layers a self-hostable Kubernetes-based control plane on top, managed with the waxctl CLI and Helm chart, with deployment targets that include AWS, GCP, and the AWS Marketplace.
APIs
Bytewax Python Library
Open-source Python library for building distributed stream processing dataflows. Provides bytewax.dataflow, bytewax.operators (including windowing), bytewax.inputs, bytewax.outp...
Bytewax Connectors
Built-in connector modules for integrating Bytewax dataflows with external systems, including Kafka (with operators and serialization submodules), files, stdio, and demo sources...
Bytewax Platform
Self-hosted control plane for securely building, deploying, and scaling Bytewax workloads on Kubernetes. Managed through the waxctl CLI and Helm chart, with deployment options i...