Skip to main content

Module group_descriptions

Module group_descriptions 

Source
Expand description

Batched group descriptions: AdminClient::describe_consumer_groups, AdminClient::describe_classic_groups, AdminClient::describe_share_groups and AdminClient::describe_streams_groups.

Each call finds the coordinator of every group with one batched FindCoordinator request and sends one describe request to each coordinator, as Apache Kafka’s Describe*GroupsHandler classes do with their CoordinatorStrategy. A request to a coordinator that fails or loses its connection finds the coordinator again.

Structs§

ConsumerGroupDescription
A consumer group, classic or KIP-848, as Apache Kafka’s ConsumerGroupDescription holds it.
DescribeGroupsOptions
The options of the describe calls, as Apache Kafka’s Describe*GroupsOptions hold them.
DescribeGroupsOptionsBuilder
Use builder syntax to set the inputs and finish with build().
MemberDescription
One member of a consumer group, as Apache Kafka’s MemberDescription holds it.

Type Aliases§

ClassicGroupDescription
A classic group’s description from DescribeGroups, as Apache Kafka’s ClassicGroupDescription holds it. This is the broker’s wire response entry for the group.
GroupDescriptions
The per-group results of a describe call: one entry for each requested group.
ShareGroupDescription
A share group’s description from ShareGroupDescribe, as Apache Kafka’s ShareGroupDescription holds it. This is the broker’s wire response entry for the group.
StreamsGroupDescription
A streams group’s description from StreamsGroupDescribe, as Apache Kafka’s StreamsGroupDescription holds it. This is the broker’s wire response entry for the group.