JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
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
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
Copyright © 2020. All rights reserved.