Skip navigation links
A B C D E F G H I J L M N O P R S T U V 

A

asJson(Object) - Static method in class io.strimzi.kafka.oauth.common.JSONUtil
Convert object to JsonNode
asListOfString(JsonNode) - Static method in class io.strimzi.kafka.oauth.common.JSONUtil
 

B

BackOffTaskScheduler - Class in io.strimzi.kafka.oauth.validator
This scheduler adds support to immediately re-schedule the execution of the provided task, using the provided ExecutorService.
BackOffTaskScheduler(ScheduledExecutorService, int, int, Runnable) - Constructor for class io.strimzi.kafka.oauth.validator.BackOffTaskScheduler
Initialise a new scheduler instance
base64encode(String) - Static method in class io.strimzi.kafka.oauth.common.OAuthAuthenticator
 
BearerTokenWithPayload - Interface in io.strimzi.kafka.oauth.common
This extension of OAuthBearerToken provides a way to associate any additional information with the token at run time, that is cached for the duration of the client session.

C

cancel(boolean) - Method in class io.strimzi.kafka.oauth.services.SessionFuture
 
cleanupExpired() - Method in class io.strimzi.kafka.oauth.services.Sessions
 
Config - Class in io.strimzi.kafka.oauth.common
 
Config() - Constructor for class io.strimzi.kafka.oauth.common.Config
Use this construtor if you only want to lookup configuration in system properties and env without any default configuration.
Config(Properties) - Constructor for class io.strimzi.kafka.oauth.common.Config
Use this constructor to provide default values in case some configuration is not set through system properties or ENV.
ConfigProperties - Class in io.strimzi.kafka.oauth.common
 
ConfigProperties(Properties) - Constructor for class io.strimzi.kafka.oauth.common.ConfigProperties
 
configure(Map<String, ?>) - Static method in class io.strimzi.kafka.oauth.services.Services
 
ConfigUtil - Class in io.strimzi.kafka.oauth.common
 
ConfigUtil() - Constructor for class io.strimzi.kafka.oauth.common.ConfigUtil
 
copy(InputStream, OutputStream) - Static method in class io.strimzi.kafka.oauth.common.IOUtil
 
createAnyHostHostnameVerifier() - Static method in class io.strimzi.kafka.oauth.common.SSLUtil
 
createHostnameVerifier(Config) - Static method in class io.strimzi.kafka.oauth.common.ConfigUtil
 
createSSLFactory(Config) - Static method in class io.strimzi.kafka.oauth.common.ConfigUtil
 
createSSLFactory(String, String, String, String) - Static method in class io.strimzi.kafka.oauth.common.SSLUtil
 
CurrentTime - Class in io.strimzi.kafka.oauth.services
 
CurrentTime() - Constructor for class io.strimzi.kafka.oauth.services.CurrentTime
 
currentTime() - Static method in class io.strimzi.kafka.oauth.services.CurrentTime
 
currentTime() - Method in interface io.strimzi.kafka.oauth.services.CurrentTimeProvider
 
CurrentTimeProvider - Interface in io.strimzi.kafka.oauth.services
 

D

DaemonThreadFactory - Class in io.strimzi.kafka.oauth.validator
Use daemon thread for refresh job
DaemonThreadFactory() - Constructor for class io.strimzi.kafka.oauth.validator.DaemonThreadFactory
 
DEFAULT - Static variable in interface io.strimzi.kafka.oauth.services.CurrentTimeProvider
 
DeprecationUtil - Class in io.strimzi.kafka.oauth.common
 
DeprecationUtil() - Constructor for class io.strimzi.kafka.oauth.common.DeprecationUtil
 

E

ECDSASignatureVerifierContext - Class in io.strimzi.kafka.oauth.validator
This class provides ECDSA signature verification support.
ECDSASignatureVerifierContext(KeyWrapper) - Constructor for class io.strimzi.kafka.oauth.validator.ECDSASignatureVerifierContext
 
equals(Object) - Method in class io.strimzi.kafka.oauth.services.ValidatorKey
 
equals(Object) - Method in class io.strimzi.kafka.oauth.services.ValidatorKey.IntrospectionValidatorKey
 
equals(Object) - Method in class io.strimzi.kafka.oauth.services.ValidatorKey.JwtValidatorKey
 
executeTask(ExecutorService, Predicate<BearerTokenWithPayload>, Consumer<BearerTokenWithPayload>) - Method in class io.strimzi.kafka.oauth.services.Sessions
 
expiresAtMs() - Method in class io.strimzi.kafka.oauth.common.TokenInfo
 

F

formatIsoDateTimeUTC(long) - Static method in class io.strimzi.kafka.oauth.common.TimeUtil
 

G

get(URI, String, Class<T>) - Static method in class io.strimzi.kafka.oauth.common.HttpUtil
 
get(URI, SSLSocketFactory, String, Class<T>) - Static method in class io.strimzi.kafka.oauth.common.HttpUtil
 
get(URI, SSLSocketFactory, HostnameVerifier, String, Class<T>) - Static method in class io.strimzi.kafka.oauth.common.HttpUtil
 
get() - Method in class io.strimzi.kafka.oauth.services.SessionFuture
 
get(long, TimeUnit) - Method in class io.strimzi.kafka.oauth.services.SessionFuture
 
get(ValidatorKey, Supplier<TokenValidator>) - Method in class io.strimzi.kafka.oauth.services.Validators
 
getClaimFromJWT(String, Object) - Static method in class io.strimzi.kafka.oauth.common.JSONUtil
Get specific claim from token.
getClaimFromJWT(JsonNode, String...) - Static method in class io.strimzi.kafka.oauth.common.JSONUtil
Get specific claim from token.
getConfigWithFallbackLookup(Config, String, String) - Static method in class io.strimzi.kafka.oauth.common.ConfigUtil
 
getCurrentTimeProvider() - Static method in class io.strimzi.kafka.oauth.services.CurrentTime
 
getCutoffIntervalSeconds() - Method in class io.strimzi.kafka.oauth.validator.BackOffTaskScheduler
 
getInstance() - Static method in class io.strimzi.kafka.oauth.services.Services
 
getMethod() - Method in exception io.strimzi.kafka.oauth.common.HttpException
 
getMinPauseSeconds() - Method in class io.strimzi.kafka.oauth.validator.BackOffTaskScheduler
 
getPayload() - Method in interface io.strimzi.kafka.oauth.common.BearerTokenWithPayload
 
getPrincipal(AccessToken, JWSInput) - Method in class io.strimzi.kafka.oauth.common.PrincipalExtractor
 
getPrincipal(JsonNode) - Method in class io.strimzi.kafka.oauth.common.PrincipalExtractor
 
getResponse() - Method in exception io.strimzi.kafka.oauth.common.HttpException
 
getSessionId() - Method in interface io.strimzi.kafka.oauth.common.BearerTokenWithPayload
This method returns an id of the current instance of this object.
getSessions() - Method in class io.strimzi.kafka.oauth.services.Services
 
getStatus() - Method in exception io.strimzi.kafka.oauth.common.HttpException
 
getSub(AccessToken) - Method in class io.strimzi.kafka.oauth.common.PrincipalExtractor
 
getSub(JsonNode) - Method in class io.strimzi.kafka.oauth.common.PrincipalExtractor
 
getToken() - Method in class io.strimzi.kafka.oauth.services.SessionFuture
 
getUri() - Method in exception io.strimzi.kafka.oauth.common.HttpException
 
getValidators() - Method in class io.strimzi.kafka.oauth.services.Services
 
getValue(String, String) - Method in class io.strimzi.kafka.oauth.common.Config
Get value for property key, returning fallback value if configuration for key is not found.
getValue(String) - Method in class io.strimzi.kafka.oauth.common.Config
Get value for property key or null if not found
getValueAsBoolean(String, boolean) - Method in class io.strimzi.kafka.oauth.common.Config
Get value for property key as boolean or fallback value if not found Valid values are: "true", "false", "yes", "no", "y", "n", "1", "0"
getValueAsInt(String, int) - Method in class io.strimzi.kafka.oauth.common.Config
Get value for property key as int or fallback value if not found

H

hashCode() - Method in class io.strimzi.kafka.oauth.services.ValidatorKey
 
hashCode() - Method in class io.strimzi.kafka.oauth.services.ValidatorKey.IntrospectionValidatorKey
 
hashCode() - Method in class io.strimzi.kafka.oauth.services.ValidatorKey.JwtValidatorKey
 
HttpException - Exception in io.strimzi.kafka.oauth.common
 
HttpException(String, URI, int, String) - Constructor for exception io.strimzi.kafka.oauth.common.HttpException
 
HttpUtil - Class in io.strimzi.kafka.oauth.common
A helper class that performs all network calls using java.net.HttpURLConnection.
HttpUtil() - Constructor for class io.strimzi.kafka.oauth.common.HttpUtil
 

I

introspectAccessToken(String, PrincipalExtractor) - Static method in class io.strimzi.kafka.oauth.common.TokenIntrospection
 
IntrospectionValidatorKey(String, String, String, String, String, String, String, String, boolean, String, String, String, String, String) - Constructor for class io.strimzi.kafka.oauth.services.ValidatorKey.IntrospectionValidatorKey
 
io.strimzi.kafka.oauth.common - package io.strimzi.kafka.oauth.common
 
io.strimzi.kafka.oauth.services - package io.strimzi.kafka.oauth.services
 
io.strimzi.kafka.oauth.validator - package io.strimzi.kafka.oauth.validator
 
IOUtil - Class in io.strimzi.kafka.oauth.common
 
IOUtil() - Constructor for class io.strimzi.kafka.oauth.common.IOUtil
 
isAccessTokenJwt(Config, Logger, String) - Static method in class io.strimzi.kafka.oauth.common.DeprecationUtil
 
isAvailable() - Static method in class io.strimzi.kafka.oauth.services.Services
 
isCancelled() - Method in class io.strimzi.kafka.oauth.services.SessionFuture
 
isConfigured() - Method in class io.strimzi.kafka.oauth.common.PrincipalExtractor
 
isDone() - Method in class io.strimzi.kafka.oauth.services.SessionFuture
 
issuedAtMs() - Method in class io.strimzi.kafka.oauth.common.TokenInfo
 
isTrue(String) - Static method in class io.strimzi.kafka.oauth.common.Config
 

J

JSONUtil - Class in io.strimzi.kafka.oauth.common
 
JSONUtil() - Constructor for class io.strimzi.kafka.oauth.common.JSONUtil
 
JWTSignatureValidator - Class in io.strimzi.kafka.oauth.validator
This class is responsible for validating the JWT token signatures during session authentication.
JWTSignatureValidator(String, SSLSocketFactory, HostnameVerifier, PrincipalExtractor, String, int, int, int, boolean, String, boolean, int) - Constructor for class io.strimzi.kafka.oauth.validator.JWTSignatureValidator
Create a new instance
JwtValidatorKey(String, String, String, String, String, String, String, String, boolean, String, int, int, int, boolean, boolean, int) - Constructor for class io.strimzi.kafka.oauth.services.ValidatorKey.JwtValidatorKey
 

L

loginWithAccessToken(String, boolean, PrincipalExtractor) - Static method in class io.strimzi.kafka.oauth.common.OAuthAuthenticator
 
loginWithClientSecret(URI, SSLSocketFactory, HostnameVerifier, String, String, boolean, PrincipalExtractor, String) - Static method in class io.strimzi.kafka.oauth.common.OAuthAuthenticator
 
loginWithRefreshToken(URI, SSLSocketFactory, HostnameVerifier, String, String, String, boolean, PrincipalExtractor, String) - Static method in class io.strimzi.kafka.oauth.common.OAuthAuthenticator
 
LogUtil - Class in io.strimzi.kafka.oauth.common
 
LogUtil() - Constructor for class io.strimzi.kafka.oauth.common.LogUtil
 

M

MAPPER - Static variable in class io.strimzi.kafka.oauth.common.JSONUtil
 
mask(String) - Static method in class io.strimzi.kafka.oauth.common.LogUtil
Return masked input text.

N

newObjectNode() - Static method in class io.strimzi.kafka.oauth.common.JSONUtil
 
newThread(Runnable) - Method in class io.strimzi.kafka.oauth.validator.DaemonThreadFactory
 

O

OAUTH_ACCESS_TOKEN_IS_JWT - Static variable in class io.strimzi.kafka.oauth.common.Config
 
OAUTH_CLIENT_ID - Static variable in class io.strimzi.kafka.oauth.common.Config
 
OAUTH_CLIENT_SECRET - Static variable in class io.strimzi.kafka.oauth.common.Config
 
OAUTH_FALLBACK_USERNAME_CLAIM - Static variable in class io.strimzi.kafka.oauth.common.Config
 
OAUTH_FALLBACK_USERNAME_PREFIX - Static variable in class io.strimzi.kafka.oauth.common.Config
 
OAUTH_SCOPE - Static variable in class io.strimzi.kafka.oauth.common.Config
 
OAUTH_SSL_ENDPOINT_IDENTIFICATION_ALGORITHM - Static variable in class io.strimzi.kafka.oauth.common.Config
 
OAUTH_SSL_SECURE_RANDOM_IMPLEMENTATION - Static variable in class io.strimzi.kafka.oauth.common.Config
 
OAUTH_SSL_TRUSTSTORE_LOCATION - Static variable in class io.strimzi.kafka.oauth.common.Config
 
OAUTH_SSL_TRUSTSTORE_PASSWORD - Static variable in class io.strimzi.kafka.oauth.common.Config
 
OAUTH_SSL_TRUSTSTORE_TYPE - Static variable in class io.strimzi.kafka.oauth.common.Config
 
OAUTH_TOKENS_NOT_JWT - Static variable in class io.strimzi.kafka.oauth.common.Config
Deprecated.
OAUTH_USERNAME_CLAIM - Static variable in class io.strimzi.kafka.oauth.common.Config
 
OAuthAuthenticator - Class in io.strimzi.kafka.oauth.common
 
OAuthAuthenticator() - Constructor for class io.strimzi.kafka.oauth.common.OAuthAuthenticator
 
OAuthIntrospectionValidator - Class in io.strimzi.kafka.oauth.validator
 
OAuthIntrospectionValidator(String, SSLSocketFactory, HostnameVerifier, PrincipalExtractor, String, String, String, String, String, String) - Constructor for class io.strimzi.kafka.oauth.validator.OAuthIntrospectionValidator
 

P

payload() - Method in class io.strimzi.kafka.oauth.common.TokenInfo
 
post(URI, String, String, String, Class<T>) - Static method in class io.strimzi.kafka.oauth.common.HttpUtil
 
post(URI, SSLSocketFactory, String, String, String, Class<T>) - Static method in class io.strimzi.kafka.oauth.common.HttpUtil
 
post(URI, SSLSocketFactory, HostnameVerifier, String, String, String, Class<T>) - Static method in class io.strimzi.kafka.oauth.common.HttpUtil
 
principal() - Method in class io.strimzi.kafka.oauth.common.TokenInfo
 
PrincipalExtractor - Class in io.strimzi.kafka.oauth.common
 
PrincipalExtractor() - Constructor for class io.strimzi.kafka.oauth.common.PrincipalExtractor
 
PrincipalExtractor(String, String, String) - Constructor for class io.strimzi.kafka.oauth.common.PrincipalExtractor
 
put(URI, String, String, String) - Static method in class io.strimzi.kafka.oauth.common.HttpUtil
 
put(URI, SSLSocketFactory, String, String, String) - Static method in class io.strimzi.kafka.oauth.common.HttpUtil
 
put(URI, SSLSocketFactory, HostnameVerifier, String, String, String) - Static method in class io.strimzi.kafka.oauth.common.HttpUtil
 
put(BearerTokenWithPayload) - Method in class io.strimzi.kafka.oauth.services.Sessions
 
putIfNotNull(Properties, String, Object) - Static method in class io.strimzi.kafka.oauth.common.ConfigUtil
 

R

readJSON(InputStream, Class<T>) - Static method in class io.strimzi.kafka.oauth.common.JSONUtil
 
remove(BearerTokenWithPayload) - Method in class io.strimzi.kafka.oauth.services.Sessions
 
request(URI, SSLSocketFactory, HostnameVerifier, String, String, String, Class<T>) - Static method in class io.strimzi.kafka.oauth.common.HttpUtil
 
resolve(Properties) - Static method in class io.strimzi.kafka.oauth.common.ConfigProperties
 
resolveAndExportToSystemProperties(Properties) - Static method in class io.strimzi.kafka.oauth.common.ConfigProperties
 
resolveTo(Properties) - Method in class io.strimzi.kafka.oauth.common.ConfigProperties
 

S

scheduleTask() - Method in class io.strimzi.kafka.oauth.validator.BackOffTaskScheduler
Schedule a task.
scope() - Method in class io.strimzi.kafka.oauth.common.TokenInfo
 
Services - Class in io.strimzi.kafka.oauth.services
This class contains singleton components shared among Kafka Broker sessions
SessionFuture<T> - Class in io.strimzi.kafka.oauth.services
 
SessionFuture(BearerTokenWithPayload, Future<T>) - Constructor for class io.strimzi.kafka.oauth.services.SessionFuture
 
Sessions - Class in io.strimzi.kafka.oauth.services
Sessions entries should automatically get cleared as KafkaPrincipals for the sessions get garbage collected by JVM.
Sessions() - Constructor for class io.strimzi.kafka.oauth.services.Sessions
 
setCurrentTimeProvider(CurrentTimeProvider) - Static method in class io.strimzi.kafka.oauth.services.CurrentTime
 
setPayload(Object) - Method in interface io.strimzi.kafka.oauth.common.BearerTokenWithPayload
 
SSLUtil - Class in io.strimzi.kafka.oauth.common
 
SSLUtil() - Constructor for class io.strimzi.kafka.oauth.common.SSLUtil
 
status() - Method in exception io.strimzi.kafka.oauth.validator.TokenValidationException
 

T

TimeUtil - Class in io.strimzi.kafka.oauth.common
 
TimeUtil() - Constructor for class io.strimzi.kafka.oauth.common.TimeUtil
 
toEnvName(String) - Static method in class io.strimzi.kafka.oauth.common.Config
Convert property key to env key.
token() - Method in class io.strimzi.kafka.oauth.common.TokenInfo
 
TokenExpiredException - Exception in io.strimzi.kafka.oauth.validator
 
TokenExpiredException() - Constructor for exception io.strimzi.kafka.oauth.validator.TokenExpiredException
 
TokenExpiredException(String) - Constructor for exception io.strimzi.kafka.oauth.validator.TokenExpiredException
 
TokenExpiredException(String, Throwable) - Constructor for exception io.strimzi.kafka.oauth.validator.TokenExpiredException
 
TokenExpiredException(Throwable) - Constructor for exception io.strimzi.kafka.oauth.validator.TokenExpiredException
 
TokenInfo - Class in io.strimzi.kafka.oauth.common
 
TokenInfo(AccessToken, String, String) - Constructor for class io.strimzi.kafka.oauth.common.TokenInfo
 
TokenInfo(String, String, String, long, long) - Constructor for class io.strimzi.kafka.oauth.common.TokenInfo
 
TokenIntrospection - Class in io.strimzi.kafka.oauth.common
 
TokenIntrospection() - Constructor for class io.strimzi.kafka.oauth.common.TokenIntrospection
 
TokenSignatureException - Exception in io.strimzi.kafka.oauth.validator
 
TokenSignatureException() - Constructor for exception io.strimzi.kafka.oauth.validator.TokenSignatureException
 
TokenSignatureException(String) - Constructor for exception io.strimzi.kafka.oauth.validator.TokenSignatureException
 
TokenSignatureException(String, Throwable) - Constructor for exception io.strimzi.kafka.oauth.validator.TokenSignatureException
 
TokenSignatureException(Throwable) - Constructor for exception io.strimzi.kafka.oauth.validator.TokenSignatureException
 
TokenValidationException - Exception in io.strimzi.kafka.oauth.validator
 
TokenValidationException() - Constructor for exception io.strimzi.kafka.oauth.validator.TokenValidationException
 
TokenValidationException(String) - Constructor for exception io.strimzi.kafka.oauth.validator.TokenValidationException
 
TokenValidationException(String, Throwable) - Constructor for exception io.strimzi.kafka.oauth.validator.TokenValidationException
 
TokenValidationException(Throwable) - Constructor for exception io.strimzi.kafka.oauth.validator.TokenValidationException
 
TokenValidationException.Status - Enum in io.strimzi.kafka.oauth.validator
 
TokenValidator - Interface in io.strimzi.kafka.oauth.validator
 
toString() - Method in class io.strimzi.kafka.oauth.common.PrincipalExtractor
 

U

urlencode(String) - Static method in class io.strimzi.kafka.oauth.common.OAuthAuthenticator
 

V

validate() - Method in class io.strimzi.kafka.oauth.common.Config
Validate configuration by checking for unknown or missing properties.
validate(String) - Method in class io.strimzi.kafka.oauth.validator.JWTSignatureValidator
 
validate(String) - Method in class io.strimzi.kafka.oauth.validator.OAuthIntrospectionValidator
 
validate(String) - Method in interface io.strimzi.kafka.oauth.validator.TokenValidator
 
ValidatorKey - Class in io.strimzi.kafka.oauth.services
 
ValidatorKey.IntrospectionValidatorKey - Class in io.strimzi.kafka.oauth.services
 
ValidatorKey.JwtValidatorKey - Class in io.strimzi.kafka.oauth.services
 
Validators - Class in io.strimzi.kafka.oauth.services
 
Validators() - Constructor for class io.strimzi.kafka.oauth.services.Validators
 
value() - Method in enum io.strimzi.kafka.oauth.validator.TokenValidationException.Status
 
valueOf(String) - Static method in enum io.strimzi.kafka.oauth.validator.TokenValidationException.Status
Returns the enum constant of this type with the specified name.
values() - Static method in enum io.strimzi.kafka.oauth.validator.TokenValidationException.Status
Returns an array containing the constants of this enum type, in the order they are declared.
verify(byte[], byte[]) - Method in class io.strimzi.kafka.oauth.validator.ECDSASignatureVerifierContext
 
A B C D E F G H I J L M N O P R S T U V 
Skip navigation links

Copyright © 2022. All rights reserved.