Class TokenInformation
- java.lang.Object
-
- org.apache.kafka.common.security.token.delegation.TokenInformation
-
-
Constructor Summary
Constructors Constructor Description TokenInformation(String tokenId, KafkaPrincipal owner, Collection<KafkaPrincipal> renewers, long issueTimestamp, long maxTimestamp, long expiryTimestamp)TokenInformation(String tokenId, KafkaPrincipal owner, KafkaPrincipal tokenRequester, Collection<KafkaPrincipal> renewers, long issueTimestamp, long maxTimestamp, long expiryTimestamp)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object o)longexpiryTimestamp()static TokenInformationfromRecord(String tokenId, KafkaPrincipal owner, KafkaPrincipal tokenRequester, Collection<KafkaPrincipal> renewers, long issueTimestamp, long maxTimestamp, long expiryTimestamp)inthashCode()longissueTimestamp()longmaxTimestamp()KafkaPrincipalowner()StringownerAsString()booleanownerOrRenewer(KafkaPrincipal principal)Collection<KafkaPrincipal>renewers()Collection<String>renewersAsString()voidsetExpiryTimestamp(long expiryTimestamp)StringtokenId()KafkaPrincipaltokenRequester()StringtokenRequesterAsString()StringtoString()
-
-
-
Constructor Detail
-
TokenInformation
public TokenInformation(String tokenId, KafkaPrincipal owner, Collection<KafkaPrincipal> renewers, long issueTimestamp, long maxTimestamp, long expiryTimestamp)
-
TokenInformation
public TokenInformation(String tokenId, KafkaPrincipal owner, KafkaPrincipal tokenRequester, Collection<KafkaPrincipal> renewers, long issueTimestamp, long maxTimestamp, long expiryTimestamp)
-
-
Method Detail
-
fromRecord
public static TokenInformation fromRecord(String tokenId, KafkaPrincipal owner, KafkaPrincipal tokenRequester, Collection<KafkaPrincipal> renewers, long issueTimestamp, long maxTimestamp, long expiryTimestamp)
-
owner
public KafkaPrincipal owner()
-
ownerAsString
public String ownerAsString()
-
tokenRequester
public KafkaPrincipal tokenRequester()
-
tokenRequesterAsString
public String tokenRequesterAsString()
-
renewers
public Collection<KafkaPrincipal> renewers()
-
renewersAsString
public Collection<String> renewersAsString()
-
issueTimestamp
public long issueTimestamp()
-
expiryTimestamp
public long expiryTimestamp()
-
setExpiryTimestamp
public void setExpiryTimestamp(long expiryTimestamp)
-
tokenId
public String tokenId()
-
maxTimestamp
public long maxTimestamp()
-
ownerOrRenewer
public boolean ownerOrRenewer(KafkaPrincipal principal)
-
-