Skip to main content

Module share_group_offsets

Module share_group_offsets 

Source
Expand description

Batched share-group offset listing: AdminClient::list_share_group_offsets.

The call finds the coordinator of every group with one batched FindCoordinator request and sends one DescribeShareGroupOffsets request to each coordinator with every group that it coordinates, as Apache Kafka’s ListShareGroupOffsetsHandler does with its CoordinatorStrategy. A request to a coordinator that fails or loses its connection finds the coordinator again.

Structs§

ListShareGroupOffsetsSpec
The partitions to list for one share group, as Apache Kafka’s ListShareGroupOffsetsSpec holds them.
ListShareGroupOffsetsSpecBuilder
Use builder syntax to set the inputs and finish with build().
SharePartitionOffsetInfo
One partition’s share-group offset, as Apache Kafka’s SharePartitionOffsetInfo holds it.

Type Aliases§

ShareGroupOffsets
The offsets of one share group: each answered partition, with None for a partition that has no start offset.