krafka 0.27.0

An async Apache Kafka client in pure Rust: producer, transactions, consumer groups, share groups and admin
Documentation 
1
2
3
4
5
6
7
8
9
10

//! Where positions come from and where they go: the one `ListOffsets` path
//! and position initialisation (`reset`), leader-epoch validation and
//! truncation (`validate`), and offset commits (`commit`).

mod commit;
mod reset;
mod validate;

pub(super) use commit::CommitRequestOffsets;
pub(super) use reset::needs_metadata_refresh;