Skip to main content

OffsetCommitCallback

Type Alias OffsetCommitCallback 

Source
pub type OffsetCommitCallback = Box<dyn FnOnce(&HashMap<(String, i32), OffsetAndMetadata>, Result<(), &ConsumerError>) + Send>;
Expand description

The callback of an asynchronous commit. Kafka’s OffsetCommitCallback.

The consumer calls it once with the offsets that the commit sent and the result. An empty map means that the consumer had no position to commit.

Aliased Type§

pub struct OffsetCommitCallback(/* private fields */);