Highlights
- Adds bounded StreamsTaskRuntime assignment reconciliation.
- Preserves Kafka nullable active/standby/warmup task semantics.
- Adds canonical StreamsTaskId validation and deterministic add/remove/role-change transitions.
- Publishes the new API from a fresh external project on stable Rust and Rust 1.81.
Verification
- crates.io: kafrust-protocol 0.3.3 published before kafrust 0.3.3.
- Published Streams surface: https://github.com/TaeeunKil/kafrust/actions/runs/32380345199
- Full workspace tests, Clippy, docs, package dry-runs, and diff checks passed.
This is an alpha release. It does not claim complete Kafka Streams application compatibility or complete rust-rdkafka/Kafka replacement parity.