Skip to main content

Module group_deletions

Module group_deletions 

Source
Expand description

Batched group deletion: AdminClient::delete_consumer_groups, AdminClient::delete_share_groups and AdminClient::delete_streams_groups.

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

Type Aliases§

GroupDeletions
The per-group results of a delete call: one entry for each requested group, Ok(()) for a deleted group.