THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
public class CreateDelegationTokenResult { private final KafkaFuture<DelegationToken> delegationToken; CreateDelegationTokenResult(KafkaFuture<DelegationToken> delegationToken) { this.delegationToken = delegationToken; } /** * Returns a future which yields a delegation token */ public KafkaFuture<DelegationToken> delegationToken() { return delegationToken; } } public class CreateDelegationTokenOptions extends AbstractOptions<CreateDelegationTokenOptions> { // default value is -1, This will default the token maxLifeTime to server side config value (delegation.token.max.lifetime.ms). private long maxLifeTimeMs = -1; private List<KafkaPrincipal> renewers = new LinkedList<>(); public CreateDelegationTokenOptions renewers(List<KafkaPrincipal> renewers) { this.renewers = renewers; return this; } public List<KafkaPrincipal> renewers() { return renewers; } public CreateDelegationTokenOptions maxlifeTimeMs(long maxLifeTimeMs) { this.maxLifeTimeMs = maxLifeTimeMs; return this; } public long maxlifeTimeMs() { return maxLifeTimeMs; } } public class RenewDelegationTokenResult { private final KafkaFuture<Long> expiryTimestamp; RenewDelegationTokenResult(KafkaFuture<Long> expiryTimestamp) { this.expiryTimestamp = expiryTimestamp; } /** * Returns a future which yields expiry timestamp */ public KafkaFuture<Long> expiryTimestamp() { return expiryTimestamp; } } public class RenewDelegationTokenOptions extends AbstractOptions<RenewDelegationTokenOptions> { // default value is -1. This will default the Renew Time period to a server side config value (delegation.token.expiry.time.ms). private long renewTimePeriodMs = -1; public RenewDelegationTokenOptions renewTimePeriodMs(long renewTimePeriodMs) { this.renewTimePeriodMs = renewTimePeriodMs; return this; } public long renewTimePeriodMs() { return renewTimePeriodMs; } } public class ExpireDelegationTokenResult { private final KafkaFuture<Long> expiryTimestamp; ExpireDelegationTokenResult(KafkaFuture<Long> expiryTimestamp) { this.expiryTimestamp = expiryTimestamp; } /** * Returns a future which yields expiry timestamp */ public KafkaFuture<Long> expiryTimestamp() { return expiryTimestamp; } } public class ExpireDelegationTokenOptions extends AbstractOptions<ExpireDelegationTokenOptions> { //default value is -1. This token will get invalidated immediately private long expiryTimePeriodMs = -1; public ExpireDelegationTokenOptions expiryTimePeriodMs(long expiryTimePeriodMs) { this.expiryTimePeriodMs = expiryTimePeriodMs; return this; } public long expiryTimePeriodMs() { return expiryTimePeriodMs; } } public class DescribeDelegationTokenResult { private final KafkaFuture<List<DelegationToken>> delegationTokens; DescribeDelegationTokenResult(KafkaFuture<List<DelegationToken>> delegationTokens) { this.delegationTokens = delegationTokens; } /** * Returns a future which yields list of delegation tokens */ public KafkaFuture<List<DelegationToken>> delegationTokens() { return delegationTokens; } } public class DescribeDelegationTokenOptions extends AbstractOptions<DescribeDelegationTokenOptions> { private List<KafkaPrincipal> owners; public DescribeDelegationTokenOptions owners(List<KafkaPrincipal> owners) { this.owners = owners; return this; } public List<KafkaPrincipal> owners() { return owners; } |
...