You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
This commit was created on GitHub.com and signed with GitHub’s verified signature.
Highlights
Added producer batch APIs with input-order metadata and per-record report outcomes.
Added retry recovery for retryable partition-level Produce failures without resending successful records.
Added max_records_per_batch and max_batch_bytes producer limits.
Added the opt-in buffered producer alpha path with ProducerDelivery, explicit flush/close, and automatic linger, record-count, and byte-count flush triggers.
Added producer_buffered live smoke coverage with delivery-handle awaits and fetch-back verification.
Published Crates
kafrust-protocol 0.2.0
kafrust 0.2.0
Validation
PR CI passed on Rust 1.75.0 and stable.
Manual Live Kafka Smoke run 26999258762 passed against Kafka 3.7.2.
Fresh published-crate smoke project compiled with kafrust@0.2.0.
docs.rs pages are available for both published crates.
Known Alpha Limits
acks=0 remains unsupported because the current request loop expects broker responses.
Secured Kafka connectivity is still planned for M11.