Struct ListConsumerGroupOffsetsResult 

pub struct ListConsumerGroupOffsetsResult { /* private fields */ }

The result of Admin::list_consumer_group_offsets_with_group_specs.

Implementations

impl ListConsumerGroupOffsetsResult

pub fn partitions_to_offset_and_metadata( &self, ) -> Result<KafkaFuture<HashMap<TopicPartition, Option<OffsetAndMetadata>>>, Error>

Returns a future which yields a map of topic partitions to OffsetAndMetadata objects. If the group does not have a committed offset for this partition, the corresponding value in the returned map will be None.

Errors

• Error::is_local_illegal_state_error if offsets from multiple consumer groups were requested: use partitions_to_offset_and_metadata_with_group_id instead.

pub fn partitions_to_offset_and_metadata_with_group_id( &self, group_id: &str, ) -> Result<KafkaFuture<HashMap<TopicPartition, Option<OffsetAndMetadata>>>, Error>

Returns a future which yields a map of topic partitions to OffsetAndMetadata for the specified group. A None value indicates the group has no committed offset for that partition.

Arguments

• group_id - the group id.

Errors

Returns an error answering Error::is_local_illegal_argument_error if offsets for the given group were not requested.

pub fn all( &self, ) -> KafkaFuture<HashMap<String, HashMap<TopicPartition, Option<OffsetAndMetadata>>>>

Returns a future which yields all group offsets, if requests for all the groups succeed.

Trait Implementations

impl Clone for ListConsumerGroupOffsetsResult

fn clone(&self) -> ListConsumerGroupOffsetsResult

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ListConsumerGroupOffsetsResult

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.