...

Public Interfaces

We will add new APIs

*getDelegationToken(request: DelegationTokenRequest): DelegationTokenResponse

**class DelegationTokenRequest(renewer: option(KafkaPrincipal) = None, maxLifeTime: long = -1)

**class DelegationTokenResponse(owner:  KafkaPrincipal,  expiryTimeMillis: long, renewer: option(KafkaPrincipal) = None, maxLifeTime: long = -1, tokenId: String, hmac: byte[])  

*renewDelegationToken(request: RenewDelegationTokenRequest): DelegationTokenResponse

**class RenewDelegationTokenRequest(hmac: byte[], expiryTimeMillis: long) 

*expireToken(request: ExpireTokenRequest)

**class ExpireTokenRequest(hmac: byte[], expireAt: long  = Systemtime.currentTimeMillis)

...