Module delegation_tokens 

KIP-48 delegation tokens, as Kafka’s Admin.createDelegationToken, renewDelegationToken, expireDelegationToken, and describeDelegationToken.

Each call takes an options struct that mirrors Kafka’s CreateDelegationTokenOptions, RenewDelegationTokenOptions, ExpireDelegationTokenOptions, or DescribeDelegationTokenOptions, and sends one request on the admin connection, as KafkaAdminClient sends it to the least-loaded node. A non-zero top-level error code becomes AdminError::Broker, as Kafka completes the call with response.error().exception().

Structs

CreateDelegationTokenOptions

What AdminClientLike::create_delegation_token asks for, as Kafka’s CreateDelegationTokenOptions.

CreateDelegationTokenOptionsBuilder

Use builder syntax to set the inputs and finish with build().

DelegationToken

One delegation token, as Kafka’s DelegationToken with its TokenInformation.

DescribeDelegationTokenOptions

What AdminClientLike::describe_delegation_token asks for, as Kafka’s DescribeDelegationTokenOptions.

DescribeDelegationTokenOptionsBuilder

Use builder syntax to set the inputs and finish with build().

ExpireDelegationTokenOptions

What AdminClientLike::expire_delegation_token asks for, as Kafka’s ExpireDelegationTokenOptions.

ExpireDelegationTokenOptionsBuilder

Use builder syntax to set the inputs and finish with build().

RenewDelegationTokenOptions

What AdminClientLike::renew_delegation_token asks for, as Kafka’s RenewDelegationTokenOptions.

RenewDelegationTokenOptionsBuilder

Use builder syntax to set the inputs and finish with build().