io.confluent.kafka.common.multitenant.oauth

Class OAuthBearerJwsToken

java.lang.Object

io.confluent.kafka.common.multitenant.oauth.OAuthBearerJwsToken

All Implemented Interfaces:

org.apache.kafka.common.security.oauthbearer.OAuthBearerToken

public class OAuthBearerJwsToken
extends Object
implements org.apache.kafka.common.security.oauthbearer.OAuthBearerToken

Field Summary

Fields

Modifier and Type	Field and Description
static String	OAUTH_IDENTITY_POOL_PROPERTY_KEY
static String	OAUTH_IDENTITY_POOL_PROVIDER_ID_PROPERTY_KEY
static String	OAUTH_NEGOTIATED_LOGICAL_CLUSTER_PROPERTY_KEY
static String	USER_RESOURCE_ID_CLAIM

Constructor Summary

Constructors

Constructor and Description
OAuthBearerJwsToken(String value, Set<String> scope, long lifetimeMs, String principalName, Long startTimeMs)
OAuthBearerJwsToken(String value, Set<String> scope, long lifetimeMs, String principalName, Long startTimeMs, Map<String,Object> jwtClaims)
OAuthBearerJwsToken(String value, Set<String> scope, long lifetimeMs, String principalName, Long startTimeMs, Map<String,Object> jwtClaims, String issuer)

Method Summary

Modifier and Type	Method and Description
String	issuer()
Map<String,Object>	jwtClaims()
long	lifetimeMs()
String	principalName()
Set<String>	scope()
Long	startTimeMs()
String	value()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

OAUTH_NEGOTIATED_LOGICAL_CLUSTER_PROPERTY_KEY

public static final String OAUTH_NEGOTIATED_LOGICAL_CLUSTER_PROPERTY_KEY

See Also:

Constant Field Values

USER_RESOURCE_ID_CLAIM

public static final String USER_RESOURCE_ID_CLAIM

See Also:

Constant Field Values

OAUTH_IDENTITY_POOL_PROPERTY_KEY

public static final String OAUTH_IDENTITY_POOL_PROPERTY_KEY

See Also:

Constant Field Values

OAUTH_IDENTITY_POOL_PROVIDER_ID_PROPERTY_KEY

public static final String OAUTH_IDENTITY_POOL_PROVIDER_ID_PROPERTY_KEY

See Also:

Constant Field Values

Constructor Detail

OAuthBearerJwsToken

public OAuthBearerJwsToken(String value,
                           Set<String> scope,
                           long lifetimeMs,
                           String principalName,
                           Long startTimeMs)

OAuthBearerJwsToken

public OAuthBearerJwsToken(String value,
                           Set<String> scope,
                           long lifetimeMs,
                           String principalName,
                           Long startTimeMs,
                           Map<String,Object> jwtClaims)

OAuthBearerJwsToken

public OAuthBearerJwsToken(String value,
                           Set<String> scope,
                           long lifetimeMs,
                           String principalName,
                           Long startTimeMs,
                           Map<String,Object> jwtClaims,
                           String issuer)

Method Detail

value

public String value()

Specified by:

value in interface org.apache.kafka.common.security.oauthbearer.OAuthBearerToken

scope

public Set<String> scope()

Specified by:

scope in interface org.apache.kafka.common.security.oauthbearer.OAuthBearerToken

lifetimeMs

public long lifetimeMs()

Specified by:

lifetimeMs in interface org.apache.kafka.common.security.oauthbearer.OAuthBearerToken

principalName

public String principalName()

Specified by:

principalName in interface org.apache.kafka.common.security.oauthbearer.OAuthBearerToken

startTimeMs

public Long startTimeMs()

Specified by:

startTimeMs in interface org.apache.kafka.common.security.oauthbearer.OAuthBearerToken

jwtClaims

public Map<String,Object> jwtClaims()

issuer

public String issuer()