Skip to main content

commit_refusals

Function commit_refusals 

Source
pub fn commit_refusals(outcomes: &[ConsumerGroupOffsetOutcome]) -> Vec<String>
Expand description

Every partition the coordinator refused, as topic-partition: NAME (code).

A commit is per-partition on the wire, so a partial refusal is possible and silence about it would report a restore that put back fewer offsets than it claims.