io.confluent.kafka.schemaregistry.client

Class SchemaRegistryClientConfig

java.lang.Object

io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

public class SchemaRegistryClientConfig
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	BASIC_AUTH_CREDENTIALS_SOURCE
static String	BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS
static short	BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS_DEFAULT
static String	BEARER_AUTH_CLIENT_ID
static String	BEARER_AUTH_CLIENT_SECRET
static String	BEARER_AUTH_CREDENTIALS_SOURCE
static String	BEARER_AUTH_CUSTOM_PROVIDER_CLASS
static String	BEARER_AUTH_IDENTITY_POOL_ID
static String	BEARER_AUTH_ISSUER_ENDPOINT_URL
static String	BEARER_AUTH_LOGICAL_CLUSTER
static String	BEARER_AUTH_SCOPE
static String	BEARER_AUTH_SCOPE_CLAIM_NAME
static String	BEARER_AUTH_SCOPE_CLAIM_NAME_DEFAULT
static String	BEARER_AUTH_SUB_CLAIM_NAME
static String	BEARER_AUTH_SUB_CLAIM_NAME_DEFAULT
static String	BEARER_AUTH_TOKEN_CONFIG
static String	CLIENT_NAMESPACE
static String	HTTP_CONNECT_TIMEOUT_MS
static int	HTTP_CONNECT_TIMEOUT_MS_DEFAULT
static String	HTTP_READ_TIMEOUT_MS
static int	HTTP_READ_TIMEOUT_MS_DEFAULT
static String	LATEST_CACHE_TTL_CONFIG
static long	LATEST_CACHE_TTL_DEFAULT
static String	MAX_RETRIES_CONFIG
static int	MAX_RETRIES_DEFAULT
static String	MISSING_CACHE_SIZE_CONFIG
static String	MISSING_ID_CACHE_TTL_CONFIG
static String	MISSING_SCHEMA_CACHE_TTL_CONFIG
static String	MISSING_VERSION_CACHE_TTL_CONFIG
static String	PROXY_HOST
static String	PROXY_PORT
static String	RETRIES_MAX_WAIT_MS_CONFIG
static int	RETRIES_MAX_WAIT_MS_DEFAULT
static String	RETRIES_WAIT_MS_CONFIG
static int	RETRIES_WAIT_MS_DEFAULT
static String	SCHEMA_REGISTRY_USER_INFO_CONFIG Deprecated. use USER_INFO_CONFIG instead
static String	USER_INFO_CONFIG

Constructor Summary

Constructors

Constructor and Description
SchemaRegistryClientConfig()

Method Summary

Modifier and Type	Method and Description
static short	getBearerAuthCacheExpiryBufferSeconds(Map<String,?> configs)
static String	getBearerAuthScopeClaimName(Map<String,?> configs)
static String	getBearerAuthSubClaimName(Map<String,?> configs)
static Integer	getHttpConnectTimeoutMs(Map<String,?> configs)
static Integer	getHttpReadTimeoutMs(Map<String,?> configs)
static long	getLatestTTL(Map<String,?> configs)
static int	getMaxMissingCacheSize(Map<String,?> configs)
static Integer	getMaxRetries(Map<String,?> configs)
static long	getMissingIdTTL(Map<String,?> configs)
static long	getMissingSchemaTTL(Map<String,?> configs)
static long	getMissingVersionTTL(Map<String,?> configs)
static Integer	getRetriesMaxWaitMs(Map<String,?> configs)
static Integer	getRetriesWaitMs(Map<String,?> configs)
static void	withClientSslSupport(org.apache.kafka.common.config.ConfigDef configDef, String namespace)

Methods inherited from class java.lang.Object

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

Field Detail

CLIENT_NAMESPACE

public static final String CLIENT_NAMESPACE

See Also:

Constant Field Values

BASIC_AUTH_CREDENTIALS_SOURCE

public static final String BASIC_AUTH_CREDENTIALS_SOURCE

See Also:

Constant Field Values

SCHEMA_REGISTRY_USER_INFO_CONFIG

@Deprecated
public static final String SCHEMA_REGISTRY_USER_INFO_CONFIG

Deprecated. use USER_INFO_CONFIG instead

See Also:

Constant Field Values

USER_INFO_CONFIG

public static final String USER_INFO_CONFIG

See Also:

Constant Field Values

HTTP_CONNECT_TIMEOUT_MS

public static final String HTTP_CONNECT_TIMEOUT_MS

See Also:

Constant Field Values

HTTP_CONNECT_TIMEOUT_MS_DEFAULT

public static final int HTTP_CONNECT_TIMEOUT_MS_DEFAULT

See Also:

Constant Field Values

HTTP_READ_TIMEOUT_MS

public static final String HTTP_READ_TIMEOUT_MS

See Also:

Constant Field Values

HTTP_READ_TIMEOUT_MS_DEFAULT

public static final int HTTP_READ_TIMEOUT_MS_DEFAULT

See Also:

Constant Field Values

MAX_RETRIES_CONFIG

public static final String MAX_RETRIES_CONFIG

See Also:

Constant Field Values

MAX_RETRIES_DEFAULT

public static final int MAX_RETRIES_DEFAULT

See Also:

Constant Field Values

RETRIES_WAIT_MS_CONFIG

public static final String RETRIES_WAIT_MS_CONFIG

See Also:

Constant Field Values

RETRIES_WAIT_MS_DEFAULT

public static final int RETRIES_WAIT_MS_DEFAULT

See Also:

Constant Field Values

RETRIES_MAX_WAIT_MS_CONFIG

public static final String RETRIES_MAX_WAIT_MS_CONFIG

See Also:

Constant Field Values

RETRIES_MAX_WAIT_MS_DEFAULT

public static final int RETRIES_MAX_WAIT_MS_DEFAULT

See Also:

Constant Field Values

BEARER_AUTH_CREDENTIALS_SOURCE

public static final String BEARER_AUTH_CREDENTIALS_SOURCE

See Also:

Constant Field Values

BEARER_AUTH_TOKEN_CONFIG

public static final String BEARER_AUTH_TOKEN_CONFIG

See Also:

Constant Field Values

PROXY_HOST

public static final String PROXY_HOST

See Also:

Constant Field Values

PROXY_PORT

public static final String PROXY_PORT

See Also:

Constant Field Values

LATEST_CACHE_TTL_CONFIG

public static final String LATEST_CACHE_TTL_CONFIG

See Also:

Constant Field Values

LATEST_CACHE_TTL_DEFAULT

public static final long LATEST_CACHE_TTL_DEFAULT

See Also:

Constant Field Values

MISSING_CACHE_SIZE_CONFIG

public static final String MISSING_CACHE_SIZE_CONFIG

See Also:

Constant Field Values

MISSING_ID_CACHE_TTL_CONFIG

public static final String MISSING_ID_CACHE_TTL_CONFIG

See Also:

Constant Field Values

MISSING_VERSION_CACHE_TTL_CONFIG

public static final String MISSING_VERSION_CACHE_TTL_CONFIG

See Also:

Constant Field Values

MISSING_SCHEMA_CACHE_TTL_CONFIG

public static final String MISSING_SCHEMA_CACHE_TTL_CONFIG

See Also:

Constant Field Values

BEARER_AUTH_ISSUER_ENDPOINT_URL

public static final String BEARER_AUTH_ISSUER_ENDPOINT_URL

See Also:

Constant Field Values

BEARER_AUTH_CLIENT_ID

public static final String BEARER_AUTH_CLIENT_ID

See Also:

Constant Field Values

BEARER_AUTH_CLIENT_SECRET

public static final String BEARER_AUTH_CLIENT_SECRET

See Also:

Constant Field Values

BEARER_AUTH_SCOPE

public static final String BEARER_AUTH_SCOPE

See Also:

Constant Field Values

BEARER_AUTH_SCOPE_CLAIM_NAME

public static final String BEARER_AUTH_SCOPE_CLAIM_NAME

See Also:

Constant Field Values

BEARER_AUTH_SCOPE_CLAIM_NAME_DEFAULT

public static final String BEARER_AUTH_SCOPE_CLAIM_NAME_DEFAULT

See Also:

Constant Field Values

BEARER_AUTH_SUB_CLAIM_NAME

public static final String BEARER_AUTH_SUB_CLAIM_NAME

See Also:

Constant Field Values

BEARER_AUTH_SUB_CLAIM_NAME_DEFAULT

public static final String BEARER_AUTH_SUB_CLAIM_NAME_DEFAULT

See Also:

Constant Field Values

BEARER_AUTH_LOGICAL_CLUSTER

public static final String BEARER_AUTH_LOGICAL_CLUSTER

See Also:

Constant Field Values

BEARER_AUTH_IDENTITY_POOL_ID

public static final String BEARER_AUTH_IDENTITY_POOL_ID

See Also:

Constant Field Values

BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS

public static final String BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS

See Also:

Constant Field Values

BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS_DEFAULT

public static final short BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS_DEFAULT

See Also:

Constant Field Values

BEARER_AUTH_CUSTOM_PROVIDER_CLASS

public static final String BEARER_AUTH_CUSTOM_PROVIDER_CLASS

See Also:

Constant Field Values

Constructor Detail

SchemaRegistryClientConfig

public SchemaRegistryClientConfig()

Method Detail

withClientSslSupport

public static void withClientSslSupport(org.apache.kafka.common.config.ConfigDef configDef,
                                        String namespace)

getHttpConnectTimeoutMs

public static Integer getHttpConnectTimeoutMs(Map<String,?> configs)

getHttpReadTimeoutMs

public static Integer getHttpReadTimeoutMs(Map<String,?> configs)

getMaxRetries

public static Integer getMaxRetries(Map<String,?> configs)

getRetriesWaitMs

public static Integer getRetriesWaitMs(Map<String,?> configs)

getRetriesMaxWaitMs

public static Integer getRetriesMaxWaitMs(Map<String,?> configs)

getLatestTTL

public static long getLatestTTL(Map<String,?> configs)

getMissingIdTTL

public static long getMissingIdTTL(Map<String,?> configs)

getMissingVersionTTL

public static long getMissingVersionTTL(Map<String,?> configs)

getMissingSchemaTTL

public static long getMissingSchemaTTL(Map<String,?> configs)

getMaxMissingCacheSize

public static int getMaxMissingCacheSize(Map<String,?> configs)

getBearerAuthCacheExpiryBufferSeconds

public static short getBearerAuthCacheExpiryBufferSeconds(Map<String,?> configs)

getBearerAuthScopeClaimName

public static String getBearerAuthScopeClaimName(Map<String,?> configs)

getBearerAuthSubClaimName

public static String getBearerAuthSubClaimName(Map<String,?> configs)