THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
public class TokenInformation { private KafkaPrincipal owner; private KafkaPrincipal tokenRequester; /// New private Collection<KafkaPrincipal> renewers; private long issueTimestamp; private long maxTimestamp; private long expiryTimestamp; private String tokenId; public TokenInformation(String tokenId, KafkaPrincipal owner, KafkaPrincipal tokenRequester, Collection<KafkaPrincipal> renewers, long issueTimestamp, long maxTimestamp, long expiryTimestamp) { .... .... } } |
ACL Changes:
We like to add two new Operations "CREATE_TOKENS", "DESCRIBE_TOKENS" on cluster resource, to allow users create token for other users and describe others tokens.
Owners/renewers/token requester principals can always renew/expire/describe their own tokens.
Operation | Resource | API |
---|---|---|
CREATE_TOKENS | Cluster | createTokens for other users // New |
DESCRIBE_TOKENS | Cluster | describeTokens for others tokens // New |
DESCRIBE | Token | describeTokens for a given tokenId //Existing |
DelegationTokenCommand Changes:
...