Index

A B C D E F G H I J K L M N O P Q R S T U V W X
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

AbstractSchemaProvider - Class in io.confluent.kafka.schemaregistry

AbstractSchemaProvider() - Constructor for class io.confluent.kafka.schemaregistry.AbstractSchemaProvider

ACCEPT_UNKNOWN_PROPERTIES - Static variable in class io.confluent.kafka.schemaregistry.client.rest.RestService

addLogicalTypeConversion(GenericData) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

addOriginalConfigs() - Method in class io.confluent.kafka.schemaregistry.rules.DlqAction

addOriginalConfigs() - Method in interface io.confluent.kafka.schemaregistry.rules.RuleBase

addProviders(List<SchemaProvider>) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

alias() - Method in interface io.confluent.kafka.schemaregistry.client.security.basicauth.BasicAuthCredentialProvider

alias() - Method in class io.confluent.kafka.schemaregistry.client.security.basicauth.SaslBasicAuthCredentialProvider

alias() - Method in class io.confluent.kafka.schemaregistry.client.security.basicauth.UrlBasicAuthCredentialProvider

alias() - Method in class io.confluent.kafka.schemaregistry.client.security.basicauth.UserInfoCredentialProvider

alias() - Method in interface io.confluent.kafka.schemaregistry.client.security.bearerauth.BearerAuthCredentialProvider

alias() - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.CustomBearerAuthCredentialProvider

alias() - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.OauthCredentialProvider

alias() - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.SaslOauthCredentialProvider

alias() - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.StaticTokenCredentialProvider

ALIASES_DESC - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.ExtendedSchema

ALL - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.ExecutionEnvironment

applyDefaults(boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

Applies defaults for association creation or upsert.

applyDefaults(boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateOp

Applies defaults for association creation or upsert.

ARRAY - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.RuleContext.Type

Association - Class in io.confluent.kafka.schemaregistry.client.rest.entities

Association(String, String, String, String, String, String, String, LifecyclePolicy, boolean) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Association

Association(String, String, String, String, String, String, String, LifecyclePolicy, boolean, Long, Long) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Association

AssociationBatchGetRequest - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

AssociationBatchGetRequest(List<AssociationGetRequest>) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationBatchGetRequest

AssociationBatchRequest - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

AssociationBatchRequest(List<AssociationOpRequest>) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationBatchRequest

AssociationBatchResponse - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

AssociationBatchResponse(List<AssociationResult>) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationBatchResponse

AssociationCreateOp - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

AssociationCreateOp(String, String, LifecyclePolicy, Boolean, RegisterSchemaRequest, Boolean) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOp

AssociationCreateOrUpdateInfo - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

AssociationCreateOrUpdateInfo(AssociationCreateOrUpdateOp) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

AssociationCreateOrUpdateInfo(String, String, LifecyclePolicy, Boolean, RegisterSchemaRequest, Boolean) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

AssociationCreateOrUpdateOp - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

AssociationCreateOrUpdateOp(OpType, String, String, LifecyclePolicy, Boolean, RegisterSchemaRequest, Boolean) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateOp

AssociationCreateOrUpdateRequest - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

AssociationCreateOrUpdateRequest(AssociationOpRequest, AssociationOp) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateRequest

AssociationCreateOrUpdateRequest(String, String, String, String, List<AssociationCreateOrUpdateInfo>) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateRequest

AssociationDeleteOp - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

AssociationDeleteOp(String) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationDeleteOp

AssociationDeleteOp(String, Boolean) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationDeleteOp

AssociationGetRequest - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

AssociationGetRequest(String, String, String, String, List<String>, LifecyclePolicy) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationGetRequest

AssociationGetRequest(String, String, String, List<String>, LifecyclePolicy) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationGetRequest

AssociationGetRequest(String, String, List<String>, LifecyclePolicy) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationGetRequest

AssociationInfo - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

AssociationInfo(String, String, LifecyclePolicy, boolean, Schema) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationInfo

AssociationOp - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

AssociationOp(OpType) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOp

AssociationOpRequest - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

AssociationOpRequest(String, String, String, String, List<? extends AssociationOp>) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOpRequest

AssociationResponse - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

AssociationResponse(String, String, String, String, List<AssociationInfo>) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResponse

AssociationResult - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

AssociationResult(ErrorMessage, AssociationResponse) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResult

ASSOCIATIONS_DESC - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.ExtendedSchema

AssociationUpsertOp - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

AssociationUpsertOp(String, String, LifecyclePolicy, Boolean, RegisterSchemaRequest, Boolean) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationUpsertOp

AvroSchema - Class in io.confluent.kafka.schemaregistry.avro

AvroSchema(String) - Constructor for class io.confluent.kafka.schemaregistry.avro.AvroSchema

AvroSchema(String, List<SchemaReference>, Map<String, String>, Metadata, RuleSet, Integer, boolean) - Constructor for class io.confluent.kafka.schemaregistry.avro.AvroSchema

AvroSchema(String, List<SchemaReference>, Map<String, String>, Integer) - Constructor for class io.confluent.kafka.schemaregistry.avro.AvroSchema

AvroSchema(String, List<SchemaReference>, Map<String, String>, Integer, boolean) - Constructor for class io.confluent.kafka.schemaregistry.avro.AvroSchema

AvroSchema(Schema) - Constructor for class io.confluent.kafka.schemaregistry.avro.AvroSchema

AvroSchema(Schema, Integer) - Constructor for class io.confluent.kafka.schemaregistry.avro.AvroSchema

AvroSchema(Schema, List<SchemaReference>, Map<String, String>, Integer) - Constructor for class io.confluent.kafka.schemaregistry.avro.AvroSchema

AvroSchema.Format - Enum Class in io.confluent.kafka.schemaregistry.avro

AvroSchemaProvider - Class in io.confluent.kafka.schemaregistry.avro

AvroSchemaProvider() - Constructor for class io.confluent.kafka.schemaregistry.avro.AvroSchemaProvider

AvroSchemaUtils - Class in io.confluent.kafka.schemaregistry.avro

AvroSchemaUtils() - Constructor for class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

B

BACKWARD - Enum constant in enum class io.confluent.kafka.schemaregistry.CompatibilityLevel

BACKWARD_CHECKER - Static variable in class io.confluent.kafka.schemaregistry.CompatibilityChecker

BACKWARD_TRANSITIVE - Enum constant in enum class io.confluent.kafka.schemaregistry.CompatibilityLevel

BACKWARD_TRANSITIVE_CHECKER - Static variable in class io.confluent.kafka.schemaregistry.CompatibilityChecker

BASIC_AUTH_CREDENTIALS_SOURCE - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

BasicAuthCredentialProvider - Interface in io.confluent.kafka.schemaregistry.client.security.basicauth

BasicAuthCredentialProviderFactory - Class in io.confluent.kafka.schemaregistry.client.security.basicauth

BasicAuthCredentialProviderFactory() - Constructor for class io.confluent.kafka.schemaregistry.client.security.basicauth.BasicAuthCredentialProviderFactory

batchGetAssociations(boolean, AssociationBatchGetRequest) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

batchGetAssociations(boolean, AssociationBatchGetRequest) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

batchGetAssociations(Map<String, String>, boolean, AssociationBatchGetRequest) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

BEARER_AUTH_CACHE_EXPIRY_BUFFER_SECONDS_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

BEARER_AUTH_CLIENT_ID - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

BEARER_AUTH_CLIENT_SECRET - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

BEARER_AUTH_CREDENTIALS_SOURCE - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

BEARER_AUTH_CUSTOM_PROVIDER_CLASS - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

BEARER_AUTH_IDENTITY_POOL_ID - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

BEARER_AUTH_ISSUER_ENDPOINT_URL - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

BEARER_AUTH_LOGICAL_CLUSTER - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

BEARER_AUTH_SCOPE - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

BEARER_AUTH_SCOPE_CLAIM_NAME - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

BEARER_AUTH_SCOPE_CLAIM_NAME_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

BEARER_AUTH_SUB_CLAIM_NAME - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

BEARER_AUTH_SUB_CLAIM_NAME_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

BEARER_AUTH_TOKEN_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

BearerAuthCredentialProvider - Interface in io.confluent.kafka.schemaregistry.client.security.bearerauth

BearerAuthCredentialProviderFactory - Class in io.confluent.kafka.schemaregistry.client.security.bearerauth

BearerAuthCredentialProviderFactory() - Constructor for class io.confluent.kafka.schemaregistry.client.security.bearerauth.BearerAuthCredentialProviderFactory

BOOLEAN - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.RuleContext.Type

BoundedConcurrentHashMap<K,V> - Class in io.confluent.kafka.schemaregistry.utils

Deprecated.

BoundedConcurrentHashMap() - Constructor for class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Creates a new, empty map with the default maximum capacity

BoundedConcurrentHashMap(int) - Constructor for class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Creates a new, empty map with the specified maximum capacity, default concurrency level and LRU eviction policy.

BoundedConcurrentHashMap(int, int) - Constructor for class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Creates a new, empty map with the specified maximum capacity, load factor, concurrency level and LRU eviction policy.

BoundedConcurrentHashMap(int, int, BoundedConcurrentHashMap.Eviction) - Constructor for class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Creates a new, empty map with the specified maximum capacity, load factor, concurrency level and eviction strategy.

BoundedConcurrentHashMap(int, int, BoundedConcurrentHashMap.Eviction, BoundedConcurrentHashMap.EvictionListener<K, V>) - Constructor for class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Creates a new, empty map with the specified maximum capacity, load factor and concurrency level.

BoundedConcurrentHashMap.Eviction - Enum Class in io.confluent.kafka.schemaregistry.utils

Deprecated.

BoundedConcurrentHashMap.EvictionListener<K,V> - Interface in io.confluent.kafka.schemaregistry.utils

Deprecated.

BoundedConcurrentHashMap.EvictionPolicy<K,V> - Interface in io.confluent.kafka.schemaregistry.utils

Deprecated.

build(Object...) - Method in class io.confluent.kafka.schemaregistry.client.rest.UriBuilder

buildConnection(URL, String, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

BYTES - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.RuleContext.Type

C

CACHE_EXPIRY_THRESHOLD - Static variable in class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.OauthTokenCache

CachedOauthTokenRetriever - Class in io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth

CachedOauthTokenRetriever is an wrapper around AccessTokenRetriever that will communicate with an OAuth/OIDC provider directly via HTTP to post client credentials (SchemaRegistryClientConfig.BEARER_AUTH_CLIENT_ID/ SchemaRegistryClientConfig.BEARER_AUTH_CLIENT_SECRET) to a publicized token endpoint URL (SchemaRegistryClientConfig.BEARER_AUTH_ISSUER_ENDPOINT_URL) inorder to fetch an access token.

CachedOauthTokenRetriever() - Constructor for class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.CachedOauthTokenRetriever

CachedSchemaRegistryClient - Class in io.confluent.kafka.schemaregistry.client

Thread-safe Schema Registry Client with client side caching.

CachedSchemaRegistryClient(RestService, int) - Constructor for class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

CachedSchemaRegistryClient(RestService, int, List<SchemaProvider>, Map<String, ?>, Map<String, String>) - Constructor for class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

CachedSchemaRegistryClient(RestService, int, List<SchemaProvider>, Map<String, ?>, Map<String, String>, Ticker) - Constructor for class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

CachedSchemaRegistryClient(RestService, int, Map<String, ?>) - Constructor for class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

CachedSchemaRegistryClient(RestService, int, Map<String, ?>, Map<String, String>) - Constructor for class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

CachedSchemaRegistryClient(String, int) - Constructor for class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

CachedSchemaRegistryClient(String, int, List<SchemaProvider>, Map<String, ?>) - Constructor for class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

CachedSchemaRegistryClient(String, int, List<SchemaProvider>, Map<String, ?>, Map<String, String>) - Constructor for class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

CachedSchemaRegistryClient(String, int, Map<String, ?>) - Constructor for class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

CachedSchemaRegistryClient(String, int, Map<String, ?>, Map<String, String>) - Constructor for class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

CachedSchemaRegistryClient(List<String>, int) - Constructor for class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

CachedSchemaRegistryClient(List<String>, int, List<SchemaProvider>, Map<String, ?>) - Constructor for class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

CachedSchemaRegistryClient(List<String>, int, List<SchemaProvider>, Map<String, ?>, Map<String, String>) - Constructor for class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

CachedSchemaRegistryClient(List<String>, int, Map<String, ?>) - Constructor for class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

CachedSchemaRegistryClient(List<String>, int, Map<String, ?>, Map<String, String>) - Constructor for class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

calculateExponentialDelay(int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RetryExecutor

calculateTokenExpiryTime(OAuthBearerToken) - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.OauthTokenCache

canBeReadStrategy() - Method in class io.confluent.kafka.schemaregistry.SchemaValidatorBuilder

Use a strategy that validates that a schema can be read by existing schema(s) according to the JSON default schema resolution.

canLookup(ParsedSchema, SchemaVersionFetcher) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns whether the schema can be used to lookup the specified schema.

canLookupIgnoringVersion(ParsedSchema, ParsedSchema) - Static method in class io.confluent.kafka.schemaregistry.AbstractSchemaProvider

canonicalString() - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

canonicalString() - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns a canonical string representation of the schema.

canReadStrategy() - Method in class io.confluent.kafka.schemaregistry.SchemaValidatorBuilder

Use a strategy that validates that a schema can be used to read existing schema(s) according to the JSON default schema resolution.

checker(CompatibilityLevel) - Static method in class io.confluent.kafka.schemaregistry.CompatibilityChecker

checkName(String, String) - Static method in class io.confluent.kafka.schemaregistry.client.rest.utils.RestValidation

checkSubject(String) - Static method in class io.confluent.kafka.schemaregistry.client.rest.utils.RestValidation

clear() - Method in interface io.confluent.kafka.schemaregistry.ParsedSchemaHolder

Clears the schema if it can be lazily retrieved in the future.

clear() - Method in class io.confluent.kafka.schemaregistry.SimpleParsedSchemaHolder

Clears the schema if it can be lazily retrieved in the future.

clear() - Static method in class io.confluent.kafka.schemaregistry.testutil.MockSchemaRegistry

clear() - Method in class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Removes all of the mappings from this map.

clear() - Method in interface io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap.EvictionPolicy

Deprecated.

Invoked to notify EvictionPolicy implementation that all Segment entries have been cleared.

clearThreadLocalData() - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

CLIENT - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.ExecutionEnvironment

CLIENT_NAMESPACE - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

ClientAppInfoParser - Class in io.confluent.kafka.schemaregistry.utils

Utility class to read Schema Registry client application information such as version and commit ID at runtime.

ClientAppInfoParser() - Constructor for class io.confluent.kafka.schemaregistry.utils.ClientAppInfoParser

close() - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

close() - Method in class io.confluent.kafka.schemaregistry.client.config.provider.SchemaRegistryConfigProvider

close() - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

close() - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

close() - Method in interface io.confluent.kafka.schemaregistry.client.security.bearerauth.BearerAuthCredentialProvider

close() - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.CustomBearerAuthCredentialProvider

close() - Method in class io.confluent.kafka.schemaregistry.rules.DlqAction

close() - Method in class io.confluent.kafka.schemaregistry.rules.FieldRedactionExecutor.FieldRedactionExecutorTransform

close() - Method in interface io.confluent.kafka.schemaregistry.rules.FieldTransform

close() - Method in interface io.confluent.kafka.schemaregistry.rules.RuleBase

close() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext.FieldContext

COMBINED - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.RuleContext.Type

compareTo(Association) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

compareTo(ContextId) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ContextId

compareTo(Schema) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

compareTo(SchemaReference) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaReference

compareTo(SubjectVersion) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SubjectVersion

compareTo(QualifiedSubject) - Method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

CompatibilityChecker - Class in io.confluent.kafka.schemaregistry

CompatibilityCheckResponse - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

CompatibilityCheckResponse() - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.CompatibilityCheckResponse

CompatibilityLevel - Enum Class in io.confluent.kafka.schemaregistry

CompatibilityPolicy - Enum Class in io.confluent.kafka.schemaregistry

computeDelayBeforeNextRetry(int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RetryExecutor

CONDITION - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.RuleKind

Config - Class in io.confluent.kafka.schemaregistry.client.rest.entities

Config() - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Config

Config(ConfigUpdateRequest) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Config

Config(String) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Config

Config(String, Boolean, Boolean, Boolean, String, String, Metadata, Metadata, RuleSet, RuleSet) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Config

Config(String, String, Boolean, Boolean, Boolean, Boolean, String, String, String, Metadata, Metadata, RuleSet, RuleSet) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Config

configs() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext

ConfigUpdateRequest - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

ConfigUpdateRequest() - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

ConfigUpdateRequest(Config) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.AbstractSchemaProvider

configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.client.config.provider.SchemaRegistryConfigProvider

configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.client.security.basicauth.SaslBasicAuthCredentialProvider

configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.client.security.basicauth.UrlBasicAuthCredentialProvider

configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.client.security.basicauth.UserInfoCredentialProvider

configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.CustomBearerAuthCredentialProvider

configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.OauthCredentialProvider

configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.SaslOauthCredentialProvider

configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.StaticTokenCredentialProvider

configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.rules.DlqAction

configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.rules.FieldRuleExecutor

configure(Map<String, ?>) - Method in interface io.confluent.kafka.schemaregistry.rules.RuleBase

configure(Map<String, ?>) - Method in interface io.confluent.kafka.schemaregistry.SchemaProvider

configure(AccessTokenRetriever, AccessTokenValidator, OauthTokenCache) - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.CachedOauthTokenRetriever

CONFLUENT_CLIENT_VERSION - Static variable in class io.confluent.kafka.schemaregistry.client.rest.RestService

CONFLUENT_VERSION - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Metadata

contains(Object) - Method in class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Legacy method testing if some key maps into the specified value in this table.

containsKey(Object) - Method in class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Tests if the specified object is a key in this table.

containsValue(Object) - Method in class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Returns true if this map maps one or more keys to the specified value.

CONTEXT_DELIMITER - Static variable in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

CONTEXT_PREFIX - Static variable in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

CONTEXT_SEPARATOR - Static variable in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

CONTEXT_WILDCARD - Static variable in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

contextFor(String, String) - Static method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Returns the context for the given qualified subject.

ContextId - Class in io.confluent.kafka.schemaregistry.client.rest.entities

ContextId(String, Integer) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.ContextId

copy() - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

copy() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ExtendedSchema

copy() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

copy() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

copy() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaReference

copy() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

copy() - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns a copy of this schema.

copy(Metadata, RuleSet) - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

copy(Metadata, RuleSet) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns a copy of this schema, but with the given metadata and rule set.

copy(Integer) - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

copy(Integer) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns a copy of this schema, but with the given version.

copy(Integer, Integer) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

copy(List<Association>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ExtendedSchema

copy(Map<SchemaEntity, Set<String>>, Map<SchemaEntity, Set<String>>) - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

copy(Map<SchemaEntity, Set<String>>, Map<SchemaEntity, Set<String>>) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns a copy of this schema, but with the given tags.

copy(Map<SchemaEntity, Set<String>>, Map<SchemaEntity, Set<String>>, boolean) - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

copy(Map<SchemaEntity, Set<String>>, Map<SchemaEntity, Set<String>>, boolean) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns a copy of this schema, but with the given tags.

copyMessage(Object) - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

copyMessage(Object) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

copyOf(AvroSchema) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

create(String, String) - Static method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Creates a QualifiedSubject from the given tenant and qualified subject.

create(String, String, String) - Static method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Creates a QualifiedSubject from the given tenant, context, and unqualified subject.

CREATE - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.OpType

createAssociation(AssociationCreateOrUpdateRequest) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

createAssociation(AssociationCreateOrUpdateRequest) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

createAssociation(AssociationCreateOrUpdateRequest) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

createAssociation(Map<String, String>, String, Boolean, AssociationCreateOrUpdateRequest) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

createFromUnqualified(String, String) - Static method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Creates a QualifiedSubject from the given tenant and unqualified subject.

createFromUnqualified(String, String, String) - Static method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Creates a QualifiedSubject from the given tenant and unqualified context and subject.

createKeystore(String, String, Password, Password, Password, Password) - Method in class io.confluent.kafka.schemaregistry.client.security.SslFactory

createNewEntry(K, int, BoundedConcurrentHashMap.HashEntry<K, V>, V) - Method in interface io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap.EvictionPolicy

Deprecated.

createOrUpdateAssociation(AssociationCreateOrUpdateRequest) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

createOrUpdateAssociation(AssociationCreateOrUpdateRequest) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

createOrUpdateAssociation(AssociationCreateOrUpdateRequest) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

createOrUpdateAssociation(Map<String, String>, String, Boolean, AssociationCreateOrUpdateRequest) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

createSocket() - Method in class io.confluent.kafka.schemaregistry.client.ssl.HostSslSocketFactory

createSocket(String, int) - Method in class io.confluent.kafka.schemaregistry.client.ssl.HostSslSocketFactory

createSocket(String, int, InetAddress, int) - Method in class io.confluent.kafka.schemaregistry.client.ssl.HostSslSocketFactory

createSocket(InetAddress, int) - Method in class io.confluent.kafka.schemaregistry.client.ssl.HostSslSocketFactory

createSocket(InetAddress, int, InetAddress, int) - Method in class io.confluent.kafka.schemaregistry.client.ssl.HostSslSocketFactory

createSocket(Socket, InputStream, boolean) - Method in class io.confluent.kafka.schemaregistry.client.ssl.HostSslSocketFactory

createSocket(Socket, String, int, boolean) - Method in class io.confluent.kafka.schemaregistry.client.ssl.HostSslSocketFactory

current() - Method in class io.confluent.kafka.schemaregistry.client.rest.utils.UrlList

Get the current url

currentField() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext

CustomBearerAuthCredentialProvider - Class in io.confluent.kafka.schemaregistry.client.security.bearerauth

CustomBearerAuthCredentialProvider() - Constructor for class io.confluent.kafka.schemaregistry.client.security.bearerauth.CustomBearerAuthCredentialProvider

customData() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext

D

deepEquals(ParsedSchema) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Deprecated.

use ParsedSchema.equivalent(ParsedSchema) instead

DEFAULT - Enum constant in enum class io.confluent.kafka.schemaregistry.avro.AvroSchema.Format

DEFAULT_CONTEXT - Static variable in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

DEFAULT_NAME - Static variable in interface io.confluent.kafka.schemaregistry.rules.RuleBase

DEFAULT_REQUEST_PROPERTIES - Static variable in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

DEFAULT_REQUEST_PROPERTIES - Static variable in class io.confluent.kafka.schemaregistry.client.rest.RestService

DEFAULT_TENANT - Static variable in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

DELETE - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.OpType

deleteAssociations(String, String, List<String>, boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

deleteAssociations(String, String, List<String>, boolean) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

deleteAssociations(String, String, List<String>, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

deleteAssociations(Map<String, String>, String, String, List<String>, boolean, Boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

deleteCompatibility(String) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

deleteConfig(String) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

deleteConfig(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

deleteConfig(String) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

deleteConfig(Map<String, String>, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

deleteContext(Map<String, String>, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

DELETED_DESC - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

deleteMode(String) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

deleteMode(String) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

deleteSchemaVersion(String, String) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

deleteSchemaVersion(String, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

deleteSchemaVersion(String, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

deleteSchemaVersion(String, String, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

deleteSchemaVersion(Map<String, String>, String, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

deleteSchemaVersion(Map<String, String>, String, String) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

deleteSchemaVersion(Map<String, String>, String, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

deleteSchemaVersion(Map<String, String>, String, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

deleteSchemaVersion(Map<String, String>, String, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

deleteSchemaVersion(Map<String, String>, String, String, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

deleteSubject(String) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

deleteSubject(String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

deleteSubject(String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

deleteSubject(String, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

deleteSubject(Map<String, String>, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

deleteSubject(Map<String, String>, String) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

deleteSubject(Map<String, String>, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

deleteSubject(Map<String, String>, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

deleteSubject(Map<String, String>, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

deleteSubject(Map<String, String>, String, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

deleteSubjectMode(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

deleteSubjectMode(Map<String, String>, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

deleteSubjectMode(Map<String, String>, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

DESCRIPTION_CONDITION - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

Difference - Class in io.confluent.kafka.schemaregistry.avro

Difference(SchemaCompatibility.Incompatibility) - Constructor for class io.confluent.kafka.schemaregistry.avro.Difference

disjoint(Set<String>, Set<String>) - Static method in class io.confluent.kafka.schemaregistry.rules.RuleContext

DLQ_AUTO_FLUSH - Static variable in class io.confluent.kafka.schemaregistry.rules.DlqAction

DLQ_REDACT_RULE_TYPES - Static variable in class io.confluent.kafka.schemaregistry.rules.DlqAction

DLQ_REDACT_RULE_TYPES_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.rules.DlqAction

DLQ_TOPIC - Static variable in class io.confluent.kafka.schemaregistry.rules.DlqAction

DlqAction - Class in io.confluent.kafka.schemaregistry.rules

DlqAction() - Constructor for class io.confluent.kafka.schemaregistry.rules.DlqAction

DOMAIN - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.RulePhase

doPropagateSchemaTags() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

DOUBLE - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.RuleContext.Type

DOWNGRADE - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.RuleMode

dropScope(String) - Static method in class io.confluent.kafka.schemaregistry.testutil.MockSchemaRegistry

Destroy the mocked registry corresponding to the scope.

E

elements() - Method in class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Returns an enumeration of the values in this table.

EMPTY_SUBJECT_NAME - Static variable in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

enabledEnv() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext

ENCODING - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.RulePhase

ensureValid(String, Object) - Method in class io.confluent.kafka.schemaregistry.utils.EnumRecommender

enterField(Object, String, String, RuleContext.Type, Set<String>) - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext

entrySet() - Method in class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Returns a Set view of the mappings contained in this map.

ENUM - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.RuleContext.Type

EnumRecommender - Class in io.confluent.kafka.schemaregistry.utils

equals(Object) - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ContextId

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ErrorMessage

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ExtendedSchema

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Metadata

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Mode

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationBatchGetRequest

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationBatchRequest

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationBatchResponse

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOp

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateOp

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateRequest

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationDeleteOp

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationGetRequest

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationInfo

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOp

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOpRequest

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResponse

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResult

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationUpsertOp

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.CompatibilityCheckResponse

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ModeUpdateRequest

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.TagSchemaRequest

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Rule

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.RuleSet

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaEntity

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaReference

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaRegistryDeployment

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaRegistryServerVersion

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaTags

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ServerClusterId

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SubjectVersion

equals(Object) - Method in class io.confluent.kafka.schemaregistry.client.SchemaMetadata

equals(Object) - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext.FieldContext

equals(Object) - Method in class io.confluent.kafka.schemaregistry.rules.ValidationRule

equals(Object) - Method in class io.confluent.kafka.schemaregistry.rules.ValidationRuleError

equals(Object) - Method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

equivalent(ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

Returns whether the underlying raw representations are equivalent, ignoring version and references.

equivalent(ParsedSchema) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns whether the underlying raw representations are equivalent, ignoring version and references.

error() - Method in class io.confluent.kafka.schemaregistry.avro.Difference

ErrorAction - Class in io.confluent.kafka.schemaregistry.rules

ErrorAction() - Constructor for class io.confluent.kafka.schemaregistry.rules.ErrorAction

ErrorMessage - Class in io.confluent.kafka.schemaregistry.client.rest.entities

Generic JSON error message.

ErrorMessage(int, String) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.ErrorMessage

ExceptionUtils - Class in io.confluent.kafka.schemaregistry.utils

ExceptionUtils() - Constructor for class io.confluent.kafka.schemaregistry.utils.ExceptionUtils

execute() - Method in interface io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap.EvictionPolicy

Deprecated.

Invokes eviction policy algorithm and returns set of evicted entries.

execute(ValidationRule, Object, Object) - Method in interface io.confluent.kafka.schemaregistry.rules.ValidationRuleExecutor

ExecutionEnvironment - Enum Class in io.confluent.kafka.schemaregistry.client.rest.entities

ExtendedSchema - Class in io.confluent.kafka.schemaregistry.client.rest.entities

ExtendedSchema(Schema, List<String>, List<Association>) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.ExtendedSchema

ExtendedSchema(String, Integer, Integer, String, String, List<SchemaReference>, Metadata, RuleSet, String, Long, Boolean, List<String>, List<Association>) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.ExtendedSchema

F

fail(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.utils.UrlList

Declare the given url as failed.

FieldContext(Object, String, String, RuleContext.Type, Set<String>) - Constructor for class io.confluent.kafka.schemaregistry.rules.RuleContext.FieldContext

FieldRedactionExecutor - Class in io.confluent.kafka.schemaregistry.rules

FieldRedactionExecutor() - Constructor for class io.confluent.kafka.schemaregistry.rules.FieldRedactionExecutor

FieldRedactionExecutor.FieldRedactionExecutorTransform - Class in io.confluent.kafka.schemaregistry.rules

FieldRedactionExecutorTransform() - Constructor for class io.confluent.kafka.schemaregistry.rules.FieldRedactionExecutor.FieldRedactionExecutorTransform

FieldRuleExecutor - Class in io.confluent.kafka.schemaregistry.rules

A field-level rule executor.

FieldRuleExecutor() - Constructor for class io.confluent.kafka.schemaregistry.rules.FieldRuleExecutor

FIELDS_FIELD - Static variable in class io.confluent.kafka.schemaregistry.avro.AvroSchema

FieldTransform - Interface in io.confluent.kafka.schemaregistry.rules

A field transform.

findMatchingEntity(JsonNode, SchemaEntity) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

FIXED - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.RuleContext.Type

FLOAT - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.RuleContext.Type

formattedString(String) - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

formattedString(String) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns a formatted string according to a type-specific format.

forName(String) - Static method in enum class io.confluent.kafka.schemaregistry.CompatibilityLevel

forName(String) - Static method in enum class io.confluent.kafka.schemaregistry.CompatibilityPolicy

FORWARD - Enum constant in enum class io.confluent.kafka.schemaregistry.CompatibilityLevel

FORWARD_CHECKER - Static variable in class io.confluent.kafka.schemaregistry.CompatibilityChecker

FORWARD_TRANSITIVE - Enum constant in enum class io.confluent.kafka.schemaregistry.CompatibilityLevel

FORWARD_TRANSITIVE_CHECKER - Static variable in class io.confluent.kafka.schemaregistry.CompatibilityChecker

fromJson(JsonNode) - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

fromJson(JsonNode) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

fromJson(String) - Static method in class io.confluent.kafka.schemaregistry.client.rest.entities.Mode

fromJson(String) - Static method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.CompatibilityCheckResponse

fromJson(String) - Static method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

fromJson(String) - Static method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ModeUpdateRequest

fromJson(String) - Static method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

fromJson(String) - Static method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

fromJson(String) - Static method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

fromPath(String) - Static method in class io.confluent.kafka.schemaregistry.client.rest.UriBuilder

FULL - Enum constant in enum class io.confluent.kafka.schemaregistry.CompatibilityLevel

FULL_CHECKER - Static variable in class io.confluent.kafka.schemaregistry.CompatibilityChecker

FULL_TRANSITIVE - Enum constant in enum class io.confluent.kafka.schemaregistry.CompatibilityLevel

FULL_TRANSITIVE_CHECKER - Static variable in class io.confluent.kafka.schemaregistry.CompatibilityChecker

G

GATEWAY - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.ExecutionEnvironment

GENERIC_REQUEST - Static variable in class io.confluent.kafka.schemaregistry.client.rest.Versions

get(Object) - Method in class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Returns the value to which the specified key is mapped, or null if this map contains no mapping for the key.

get(String) - Static method in enum class io.confluent.kafka.schemaregistry.avro.AvroSchema.Format

get(String) - Method in class io.confluent.kafka.schemaregistry.client.config.provider.SchemaRegistryConfigProvider

Retrieves the data from schema registry at the given path.

get(String) - Static method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaEntity.EntityType

get(String, Set<String>) - Method in class io.confluent.kafka.schemaregistry.client.config.provider.SchemaRegistryConfigProvider

Retrieves the data with the given keys at the given path.

getAlias() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

getAlias() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

getAliases() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ExtendedSchema

getAliasForDeks() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

getAliasForDeks() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

getAllContextIds(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllContextIds(Map<String, String>, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllContexts() - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getAllContexts() - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getAllContexts() - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllContexts() - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getAllContexts(int, int, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllContexts(int, int, String, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllContexts(Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllContextsWithPagination(int, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllSubjects() - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getAllSubjects() - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getAllSubjects() - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllSubjects() - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getAllSubjects(boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getAllSubjects(boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllSubjects(boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getAllSubjects(String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllSubjects(Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllSubjects(Map<String, String>, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllSubjects(Map<String, String>, String, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllSubjectsById(int) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getAllSubjectsById(int) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getAllSubjectsById(int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllSubjectsById(int) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getAllSubjectsById(int, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllSubjectsById(int, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllSubjectsById(Map<String, String>, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllSubjectsById(Map<String, String>, int, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllSubjectsById(Map<String, String>, int, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllSubjectsByIdWithPagination(Map<String, String>, int, String, boolean, int, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllSubjectsByPrefix(String) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getAllSubjectsByPrefix(String) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getAllSubjectsByPrefix(String) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getAllSubjectsWithPagination(int, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllSubjectsWithPagination(Map<String, String>, int, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllVersions(String) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getAllVersions(String) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getAllVersions(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllVersions(String) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getAllVersions(String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getAllVersions(String, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getAllVersions(Map<String, String>, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllVersions(Map<String, String>, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllVersions(Map<String, String>, String, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllVersionsById(int) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getAllVersionsById(int) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getAllVersionsById(int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllVersionsById(int) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getAllVersionsById(int, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllVersionsById(int, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllVersionsById(Map<String, String>, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllVersionsById(Map<String, String>, int, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllVersionsById(Map<String, String>, int, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllVersionsByIdWithPagination(Map<String, String>, int, String, boolean, int, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAllVersionsWithPagination(Map<String, String>, String, boolean, int, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAssociations() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ExtendedSchema

getAssociations() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateRequest

getAssociations() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOpRequest

getAssociations() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResponse

getAssociationsByResourceId(String, String, List<String>, String, int, int) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getAssociationsByResourceId(String, String, List<String>, String, int, int) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getAssociationsByResourceId(String, String, List<String>, String, int, int) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getAssociationsByResourceId(Map<String, String>, String, String, List<String>, LifecyclePolicy, int, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAssociationsByResourceName(String, String, String, List<String>, String, int, int) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getAssociationsByResourceName(String, String, String, List<String>, String, int, int) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getAssociationsByResourceName(String, String, String, List<String>, String, int, int) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getAssociationsByResourceName(Map<String, String>, String, String, String, List<String>, LifecyclePolicy, int, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAssociationsBySubject(String, String, List<String>, String, int, int) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getAssociationsBySubject(String, String, List<String>, String, int, int) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getAssociationsBySubject(String, String, List<String>, String, int, int) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getAssociationsBySubject(Map<String, String>, String, String, List<String>, LifecyclePolicy, int, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getAssociationType() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

getAssociationType() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

getAssociationType() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateOp

getAssociationType() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationDeleteOp

getAssociationType() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationInfo

getAssociationTypes() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationGetRequest

getAttributes() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaRegistryDeployment

getBaseUrls() - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getBasicAuthCredentialProvider(String, Map<String, ?>) - Static method in class io.confluent.kafka.schemaregistry.client.security.basicauth.BasicAuthCredentialProviderFactory

getBearerAuthCacheExpiryBufferSeconds(Map<String, ?>) - Static method in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

getBearerAuthCredentialProvider(String, Map<String, ?>) - Static method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.BearerAuthCredentialProviderFactory

getBearerAuthScopeClaimName(Map<String, ?>) - Static method in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

getBearerAuthSubClaimName(Map<String, ?>) - Static method in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

getBearerToken(URL) - Method in interface io.confluent.kafka.schemaregistry.client.security.bearerauth.BearerAuthCredentialProvider

getBearerToken(URL) - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.CustomBearerAuthCredentialProvider

getBearerToken(URL) - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.OauthCredentialProvider

getBearerToken(URL) - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.SaslOauthCredentialProvider

getBearerToken(URL) - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.StaticTokenCredentialProvider

getByGuid(String, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getByGuid(Map<String, String>, String, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getById(int) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

Deprecated.

use SchemaRegistryClient.getSchemaById(int) instead

getByID(int) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

Deprecated.

use SchemaRegistryClient.getSchemaById(int) instead

getBySubjectAndId(String, int) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

Deprecated.

use SchemaRegistryClient.getSchemaBySubjectAndId(String, int) instead

getBySubjectAndID(String, int) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

Deprecated.

use SchemaRegistryClient.getSchemaBySubjectAndId(String, int) instead

getByVersion(String, int, boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getByVersion(String, int, boolean) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getByVersion(String, int, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getByVersion(String, int, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaVersionFetcher

getCascadeLifecycle() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationDeleteOp

getCause() - Method in class io.confluent.kafka.schemaregistry.rules.ValidationRuleError

getClientForScope(String) - Static method in class io.confluent.kafka.schemaregistry.testutil.MockSchemaRegistry

Get a client for a mocked Schema Registry.

getClientForScope(String, List<SchemaProvider>) - Static method in class io.confluent.kafka.schemaregistry.testutil.MockSchemaRegistry

Get a client for a mocked Schema Registry.

getClientForScope(List<String>, List<SchemaProvider>) - Static method in class io.confluent.kafka.schemaregistry.testutil.MockSchemaRegistry

Get a client for a mocked Schema Registry.

getClientSslConfig(Map<String, ?>) - Static method in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

getClientVersion() - Static method in class io.confluent.kafka.schemaregistry.utils.ClientAppInfoParser

Builds the Confluent-Client-Version header value.

getClusterId() - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getClusterId(Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getCommitId() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaRegistryServerVersion

getCompatibility(String) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getCompatibility(String, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getCompatibilityGroup() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

getCompatibilityGroup() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

getCompatibilityLevel() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

getCompatibilityLevel() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

getCompatibilityPolicy() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

getCompatibilityPolicy() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

getConfig(String) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getConfig(String) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getConfig(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getConfig(String) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getConfig(String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getConfig(String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getConfig(String, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getConfig(Map<String, String>, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getConfig(Map<String, String>, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getConfluentVersion() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Metadata

getConfluentVersion(Metadata) - Static method in class io.confluent.kafka.schemaregistry.AbstractSchemaProvider

getConfluentVersionNumber() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Metadata

getConfluentVersionNumber(Metadata) - Static method in class io.confluent.kafka.schemaregistry.AbstractSchemaProvider

getContainingMessage() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext.FieldContext

getContext() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ContextId

getContext() - Method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

getCreateTimestamp() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

getCurrentToken() - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.OauthTokenCache

getData(String) - Method in class io.confluent.kafka.schemaregistry.client.config.provider.SchemaRegistryConfigProvider

getData(Schema, Object, boolean, boolean) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getDatumWriter(Object, Schema, boolean) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getDatumWriter(Object, Schema, boolean, boolean) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getDefaultCipherSuites() - Method in class io.confluent.kafka.schemaregistry.client.ssl.HostSslSocketFactory

getDefaultMetadata() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

getDefaultMetadata() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

getDefaultRuleSet() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

getDefaultRuleSet() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

getDeleted() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

getDeleted() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

getDeleted() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

getDeleted() - Method in class io.confluent.kafka.schemaregistry.client.SchemaMetadata

getDeletedOnlySubjects(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getDeletedOnlyVersions(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getDetail() - Method in exception io.confluent.kafka.schemaregistry.client.rest.exceptions.IllegalPropertyException

getDoc() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Rule

getDoc() - Method in class io.confluent.kafka.schemaregistry.rules.ValidationRule

getDomainRules() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.RuleSet

getEnableAt() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.RuleSet

getEncodingRules() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.RuleSet

getEntityPath() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaEntity

getEntityType() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaEntity

getError() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOpRequest

getError() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResult

getErrorCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ErrorMessage

getErrorCode() - Method in exception io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException

getExpr() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Rule

getExpr() - Method in class io.confluent.kafka.schemaregistry.rules.ValidationRule

getFieldPath() - Method in class io.confluent.kafka.schemaregistry.rules.ValidationRuleError

getFrozen() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

getFrozen() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateOp

getFullName() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext.FieldContext

getGenericData() - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getGenericData(boolean) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getGuid() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

getGuid() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

getGuid() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

getGuid() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

getGuid() - Method in class io.confluent.kafka.schemaregistry.client.SchemaMetadata

getGuid(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getGuid(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getGuid(String, ParsedSchema) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getGuid(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getGuid(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getGuid(String, ParsedSchema, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getHttpConnectTimeoutMs(Map<String, ?>) - Static method in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

getHttpReadTimeoutMs(Map<String, ?>) - Static method in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

getId() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ContextId

getId() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

getId() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

getId() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

getId() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ServerClusterId

getId() - Method in class io.confluent.kafka.schemaregistry.client.SchemaMetadata

getId(int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getId(int, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getId(int, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getId(int, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getId(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getId(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getId(String, ParsedSchema) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getId(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getId(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getId(String, ParsedSchema, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getId(String, Schema) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

Deprecated.

getId(Map<String, String>, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getId(Map<String, String>, int, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getId(Map<String, String>, int, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getId(Map<String, String>, int, String, String, String, Set<String>, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getId(Map<String, String>, int, String, String, Set<String>, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getId(Map<String, String>, int, String, Set<String>, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getIdWithResponse(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getIdWithResponse(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getIdWithResponse(String, ParsedSchema, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getIsCompatible() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.CompatibilityCheckResponse

getKind() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Rule

getLatestSchemaMetadata(String) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getLatestSchemaMetadata(String) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getLatestSchemaMetadata(String) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getLatestTTL(Map<String, ?>) - Static method in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

getLatestVersion(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getLatestVersion(Map<String, String>, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getLatestVersion(Map<String, String>, String, String, Set<String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getLatestVersion(Map<String, String>, String, Set<String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getLatestVersionSchemaOnly(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getLatestWithMetadata(String, Map<String, String>, boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getLatestWithMetadata(String, Map<String, String>, boolean) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getLatestWithMetadata(String, Map<String, String>, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getLatestWithMetadata(String, Map<String, String>, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getLatestWithMetadata(Map<String, String>, String, Map<String, String>, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getLatestWithMetadata(Map<String, String>, String, Map<String, String>, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getLifecycle() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

getLifecycle() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

getLifecycle() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateOp

getLifecycle() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationGetRequest

getLifecycle() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationInfo

getMaxId() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

getMaxMissingCacheSize(Map<String, ?>) - Static method in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

getMaxRetries(Map<String, ?>) - Static method in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

getMessage() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ErrorMessage

getMessage() - Method in class io.confluent.kafka.schemaregistry.rules.ValidationRuleError

Optional dynamic error message returned by the rule itself — non-null when the rule expression returned a non-empty string explaining the failure (e.g.

getMessages() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.CompatibilityCheckResponse

getMetadata() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

getMetadata() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

getMetadata() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.TagSchemaRequest

getMetadata() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

getMetadata() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

getMetadata() - Method in class io.confluent.kafka.schemaregistry.client.SchemaMetadata

getMigrationRules() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.RuleSet

getMissingIdTTL(Map<String, ?>) - Static method in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

getMissingSchemaTTL(Map<String, ?>) - Static method in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

getMissingVersionTTL(Map<String, ?>) - Static method in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

getMode() - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getMode() - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getMode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Mode

getMode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ModeUpdateRequest

getMode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Rule

getMode() - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getMode() - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getMode(String) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getMode(String) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getMode(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getMode(String) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getMode(String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getName() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Rule

getName() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaReference

getName() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext.FieldContext

getName() - Method in class io.confluent.kafka.schemaregistry.rules.ValidationRule

getNewVersion() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.TagSchemaRequest

getNormalize() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

getNormalize() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateOp

getNormalizedPath() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaEntity

getOnFailure() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Rule

If the mode is WRITEREAD or UPDOWN, the on-failure action can be a comma separated pair of actions, such as "none,error".

getOnlySchemaById(int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getOnlySchemaById(Map<String, String>, int, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getOnSuccess() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Rule

If the mode is WRITEREAD or UPDOWN, the on-success action can be a comma separated pair of actions, such as "none,error".

getOptionalAlias() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

getOptionalAliasForDeks() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

getOptionalCompatibilityGroup() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

getOptionalCompatibilityLevel() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

getOptionalCompatibilityPolicy() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

getOptionalDefaultMetadata() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

getOptionalDefaultRuleSet() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

getOptionalMode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ModeUpdateRequest

getOptionalOverrideMetadata() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

getOptionalOverrideRuleSet() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

getOverrideMetadata() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

getOverrideMetadata() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

getOverrideRuleSet() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

getOverrideRuleSet() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

getParameter(String) - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext

getParams() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Rule

getParser() - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

getPrimitiveSchemas() - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getProperties() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Metadata

getPropertyName() - Method in exception io.confluent.kafka.schemaregistry.client.rest.exceptions.IllegalPropertyException

getProviders() - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getReferencedBy(String, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getReferencedBy(String, int, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getReferencedBy(Map<String, String>, String, int, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getReferencedByWithPagination(String, int, int, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getReferences() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

getReferences() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

getReferences() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

getReferences() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

getReferences() - Method in class io.confluent.kafka.schemaregistry.client.SchemaMetadata

getReflectData() - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getReflectData(boolean, boolean) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getReflectDataAllowNull() - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getRequests() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationBatchGetRequest

getRequests() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationBatchRequest

getReservedFields() - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

getResourceId() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

getResourceId() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateRequest

getResourceId() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationGetRequest

getResourceId() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOpRequest

getResourceId() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResponse

getResourceName() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

getResourceName() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateRequest

getResourceName() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationGetRequest

getResourceName() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOpRequest

getResourceName() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResponse

getResourceNamespace() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

getResourceNamespace() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateRequest

getResourceNamespace() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationGetRequest

getResourceNamespace() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOpRequest

getResourceNamespace() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResponse

getResourceType() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

getResourceType() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateRequest

getResourceType() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationGetRequest

getResourceType() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOpRequest

getResourceType() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResponse

getResult() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResult

getResults() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationBatchResponse

getRetriesMaxWaitMs(Map<String, ?>) - Static method in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

getRetriesWaitMs(Map<String, ?>) - Static method in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

getRule() - Method in exception io.confluent.kafka.schemaregistry.rules.RuleException

Returns the rule that caused this exception, or null if unknown.

getRule() - Method in class io.confluent.kafka.schemaregistry.rules.ValidationRuleError

getRules(RulePhase) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.RuleSet

getRuleSet() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

getRuleSet() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

getRuleSet() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.TagSchemaRequest

getRuleSet() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

getRuleSet() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

getRuleSet() - Method in class io.confluent.kafka.schemaregistry.client.SchemaMetadata

getRulesToMerge() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.TagSchemaRequest

getRulesToRemove() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.TagSchemaRequest

getSchema() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

getSchema() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateOp

getSchema() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationInfo

getSchema() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

getSchema() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

getSchema() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

getSchema() - Method in class io.confluent.kafka.schemaregistry.client.SchemaMetadata

getSchema() - Method in interface io.confluent.kafka.schemaregistry.ParsedSchemaAndValue

getSchema(Object) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getSchema(Object, boolean, boolean, boolean) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getSchema(Object, boolean, boolean, boolean, boolean) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getSchema(Object, boolean, boolean, boolean, boolean, boolean) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getSchemaByGuid(String, String) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getSchemaByGuid(String, String) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getSchemaByGuid(String, String) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getSchemaByGuidFromRegistry(String, String) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getSchemaById(int) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getSchemaById(int) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getSchemaById(int) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getSchemaByIdFromRegistry(int, String) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

Deprecated.

getSchemaBySubjectAndId(String, int) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getSchemaBySubjectAndId(String, int) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getSchemaBySubjectAndId(String, int) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getSchemaEntity() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaTags

getSchemaEntityByIdFromRegistry(int, String) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getSchemaEntityBySubjectAndId(String, int) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getSchemaEntityBySubjectAndId(String, int) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getSchemaEntityBySubjectAndId(String, int) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getSchemaMetadata(String, int) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getSchemaMetadata(String, int) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getSchemaMetadata(String, int) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getSchemaMetadata(String, int, boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getSchemaMetadata(String, int, boolean) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getSchemaMetadata(String, int, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getSchemaProviders() - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getSchemaRegistryDeployment() - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getSchemaRegistryDeployment() - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getSchemaRegistryDeployment() - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getSchemaRegistryDeployment() - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getSchemaRegistryServerVersion() - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getSchemaRegistryServerVersion() - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getSchemaRegistryServerVersion() - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getSchemas(String, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getSchemas(String, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getSchemas(String, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getSchemas(String, boolean, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getSchemas(Map<String, String>, String, boolean, boolean, boolean, String, Integer, Integer) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getSchemas(Map<String, String>, String, boolean, boolean, boolean, String, String, List<String>, List<LifecyclePolicyFilter>, Integer, Integer) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getSchemas(Map<String, String>, String, boolean, boolean, String, Integer, Integer) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getSchemaString() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

getSchemaTags() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

getSchemaTags() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

getSchemaTagsToAdd() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

getSchemaTagsToRemove() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

getSchemaType() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

getSchemaType() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

getSchemaType() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

getSchemaType() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

getSchemaType() - Method in class io.confluent.kafka.schemaregistry.client.SchemaMetadata

getSchemaTypes() - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getSchemaTypes(Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getScope() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ServerClusterId

getSensitive() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Metadata

getSpecificData() - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getSpecificDataForClass(Class<T>) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getSpecificDataForSchema(Schema) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getSpecificDataForSchema(Schema, boolean) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getSql() - Method in class io.confluent.kafka.schemaregistry.rules.ValidationRule

getStatus() - Method in exception io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException

getSubject() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

getSubject() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

getSubject() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateOp

getSubject() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationInfo

getSubject() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

getSubject() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaReference

getSubject() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

getSubject() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SubjectVersion

getSubject() - Method in class io.confluent.kafka.schemaregistry.client.SchemaMetadata

getSubject() - Method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

getSupportedCipherSuites() - Method in class io.confluent.kafka.schemaregistry.client.ssl.HostSslSocketFactory

getTags() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Metadata

getTags() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Rule

getTags() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaTags

getTags() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext.FieldContext

getTags(String) - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext

getTagsToAdd() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.TagSchemaRequest

getTagsToRemove() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.TagSchemaRequest

getTargetIdentityPoolId() - Method in interface io.confluent.kafka.schemaregistry.client.security.bearerauth.BearerAuthCredentialProvider

getTargetIdentityPoolId() - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.CustomBearerAuthCredentialProvider

getTargetIdentityPoolId() - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.OauthCredentialProvider

getTargetIdentityPoolId() - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.SaslOauthCredentialProvider

getTargetIdentityPoolId() - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.StaticTokenCredentialProvider

getTargetSchemaRegistry() - Method in interface io.confluent.kafka.schemaregistry.client.security.bearerauth.BearerAuthCredentialProvider

getTargetSchemaRegistry() - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.CustomBearerAuthCredentialProvider

getTargetSchemaRegistry() - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.OauthCredentialProvider

getTargetSchemaRegistry() - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.SaslOauthCredentialProvider

getTargetSchemaRegistry() - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.StaticTokenCredentialProvider

getTenant() - Method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

getThreadLocalGenericData() - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getThreadLocalReflectData() - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getThreadLocalSpecificData() - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

getTimestamp() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

getTimestamp() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

getTimestamp() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

getTimestamp() - Method in class io.confluent.kafka.schemaregistry.client.SchemaMetadata

getToken() - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.CachedOauthTokenRetriever

getType() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOp

getType() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Rule

getType() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext.FieldContext

getUpdateTimestamp() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

getUrlRandomize(Map<String, ?>) - Static method in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

getUserInfo(URL) - Method in interface io.confluent.kafka.schemaregistry.client.security.basicauth.BasicAuthCredentialProvider

getUserInfo(URL) - Method in class io.confluent.kafka.schemaregistry.client.security.basicauth.SaslBasicAuthCredentialProvider

getUserInfo(URL) - Method in class io.confluent.kafka.schemaregistry.client.security.basicauth.UrlBasicAuthCredentialProvider

getUserInfo(URL) - Method in class io.confluent.kafka.schemaregistry.client.security.basicauth.UserInfoCredentialProvider

getValue() - Method in interface io.confluent.kafka.schemaregistry.ParsedSchemaAndValue

getVersion() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

getVersion() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

getVersion() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

getVersion() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaReference

getVersion() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaRegistryServerVersion

getVersion() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

getVersion() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SubjectVersion

getVersion() - Method in class io.confluent.kafka.schemaregistry.client.SchemaMetadata

getVersion() - Static method in class io.confluent.kafka.schemaregistry.utils.ClientAppInfoParser

Returns the version of the Schema Registry client.

getVersion(String, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getVersion(String, int, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getVersion(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getVersion(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getVersion(String, ParsedSchema) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getVersion(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

getVersion(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

getVersion(String, ParsedSchema, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

getVersion(String, Schema) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

Deprecated.

getVersion(Map<String, String>, String, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getVersion(Map<String, String>, String, int, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getVersion(Map<String, String>, String, int, String, boolean, Set<String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getVersion(Map<String, String>, String, int, String, String, boolean, Set<String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

getVersionSchemaOnly(String, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

GLOBAL_CONTEXT_NAME - Static variable in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

GLOBAL_SUBJECT_NAME - Static variable in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

GUID_DESC - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

H

hasDefaultsOrOverrides() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

hashCode() - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ContextId

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ErrorMessage

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ExtendedSchema

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Metadata

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Mode

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationBatchGetRequest

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationBatchRequest

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationBatchResponse

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOp

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateOp

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateRequest

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationDeleteOp

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationGetRequest

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationInfo

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOp

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOpRequest

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResponse

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResult

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationUpsertOp

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.CompatibilityCheckResponse

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ModeUpdateRequest

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.TagSchemaRequest

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Rule

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.RuleSet

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaEntity

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaReference

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaRegistryDeployment

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaRegistryServerVersion

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaTags

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ServerClusterId

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SubjectVersion

hashCode() - Method in class io.confluent.kafka.schemaregistry.client.SchemaMetadata

hashCode() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext.FieldContext

hashCode() - Method in class io.confluent.kafka.schemaregistry.rules.ValidationRule

hashCode() - Method in class io.confluent.kafka.schemaregistry.rules.ValidationRuleError

hashCode() - Method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

hasLatestVersion(List<SchemaReference>) - Static method in class io.confluent.kafka.schemaregistry.AbstractSchemaProvider

hasRules(RulePhase, RuleMode) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.RuleSet

hasRulesWithType(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.RuleSet

hasSchemaTagsToAddOrRemove() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

hasTopLevelField(String) - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

hasTopLevelField(String) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

HEADER_PREFIX - Static variable in class io.confluent.kafka.schemaregistry.rules.DlqAction

headers() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext

HostSslSocketFactory - Class in io.confluent.kafka.schemaregistry.client.ssl

This class is a wrapper class on top of SSLSocketFactory to address issue where host name is not set on BCSSLSocket when creating a socket.

HostSslSocketFactory(SSLSocketFactory, String) - Constructor for class io.confluent.kafka.schemaregistry.client.ssl.HostSslSocketFactory

HTTP_CONNECT_TIMEOUT_MS - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

HTTP_CONNECT_TIMEOUT_MS_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

HTTP_READ_TIMEOUT_MS - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

HTTP_READ_TIMEOUT_MS_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

httpRequest(String, String, byte[], Map<String, String>, TypeReference<T>) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

Send an HTTP request.

I

ID_DESC - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

ID_EXAMPLE - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

IllegalPropertyException - Exception in io.confluent.kafka.schemaregistry.client.rest.exceptions

IllegalPropertyException(String, String) - Constructor for exception io.confluent.kafka.schemaregistry.client.rest.exceptions.IllegalPropertyException

in(E...) - Static method in class io.confluent.kafka.schemaregistry.utils.EnumRecommender

index() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext

init(RuleContext) - Method in interface io.confluent.kafka.schemaregistry.rules.FieldTransform

inlineTaggedEntities() - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

inlineTaggedEntities() - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns the inline tagged entities of the schema.

inlineTags() - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

inlineTags() - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns the set of inline tags embedded in the schema.

INSTANCE - Static variable in class io.confluent.kafka.schemaregistry.utils.JacksonMapper

INT - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.RuleContext.Type

io.confluent.kafka.schemaregistry - package io.confluent.kafka.schemaregistry

io.confluent.kafka.schemaregistry.annotations - package io.confluent.kafka.schemaregistry.annotations

io.confluent.kafka.schemaregistry.avro - package io.confluent.kafka.schemaregistry.avro

io.confluent.kafka.schemaregistry.client - package io.confluent.kafka.schemaregistry.client

io.confluent.kafka.schemaregistry.client.config.provider - package io.confluent.kafka.schemaregistry.client.config.provider

io.confluent.kafka.schemaregistry.client.rest - package io.confluent.kafka.schemaregistry.client.rest

io.confluent.kafka.schemaregistry.client.rest.entities - package io.confluent.kafka.schemaregistry.client.rest.entities

io.confluent.kafka.schemaregistry.client.rest.entities.requests - package io.confluent.kafka.schemaregistry.client.rest.entities.requests

io.confluent.kafka.schemaregistry.client.rest.exceptions - package io.confluent.kafka.schemaregistry.client.rest.exceptions

io.confluent.kafka.schemaregistry.client.rest.utils - package io.confluent.kafka.schemaregistry.client.rest.utils

io.confluent.kafka.schemaregistry.client.security - package io.confluent.kafka.schemaregistry.client.security

io.confluent.kafka.schemaregistry.client.security.basicauth - package io.confluent.kafka.schemaregistry.client.security.basicauth

io.confluent.kafka.schemaregistry.client.security.bearerauth - package io.confluent.kafka.schemaregistry.client.security.bearerauth

io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth - package io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth

io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.exceptions - package io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.exceptions

io.confluent.kafka.schemaregistry.client.ssl - package io.confluent.kafka.schemaregistry.client.ssl

io.confluent.kafka.schemaregistry.rules - package io.confluent.kafka.schemaregistry.rules

io.confluent.kafka.schemaregistry.testutil - package io.confluent.kafka.schemaregistry.testutil

io.confluent.kafka.schemaregistry.utils - package io.confluent.kafka.schemaregistry.utils

isBackwardCompatible(CompatibilityPolicy, ParsedSchema) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Checks the backward compatibility between this schema and the specified schema.

isBackwardCompatible(ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

isBackwardCompatible(ParsedSchema) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Checks the backward compatibility between this schema and the specified schema.

isCompatible(CompatibilityLevel, CompatibilityPolicy, List<ParsedSchemaHolder>) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Checks the compatibility between this schema and the specified schemas.

isCompatible(CompatibilityLevel, List<ParsedSchemaHolder>) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Checks the compatibility between this schema and the specified schemas.

isCompatible(CompatibilityPolicy, ParsedSchema, List<? extends ParsedSchema>) - Method in class io.confluent.kafka.schemaregistry.CompatibilityChecker

isCompatible(ParsedSchema, List<? extends ParsedSchema>) - Method in class io.confluent.kafka.schemaregistry.CompatibilityChecker

isCompatibleWithHolders(CompatibilityPolicy, ParsedSchema, List<ParsedSchemaHolder>) - Method in class io.confluent.kafka.schemaregistry.CompatibilityChecker

isContext(String, String) - Static method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Checks if the given qualified subject represents a context (i.e., has no subject part).

isDefaultContext(String, String) - Static method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Checks if the given qualified subject is the default context for the given tenant.

isDisabled() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Rule

isDomainOrEncodingRule() - Method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.RuleMode

isEmpty() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.RuleSet

isEmpty() - Method in class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Returns true if this map contains no key-value mappings.

isEquivalent(AssociationCreateOrUpdateInfo) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

isFipsDeployment() - Static method in class io.confluent.kafka.schemaregistry.client.ssl.HostSslSocketFactory

isForward() - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

isFrozen() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

isFrozen() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationInfo

isInCombined() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext.FieldContext

isKey() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext

isMigrationRule() - Method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.RuleMode

isNetworkConnectionException(Throwable) - Static method in class io.confluent.kafka.schemaregistry.utils.ExceptionUtils

isNew() - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

isNormalize() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

isNormalize() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

isOptionalNormalize() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

isOptionalValidateFields() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

isOptionalValidateNewSchemas() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

isOptionalValidateRules() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

isPreserveSource(RuleContext) - Method in class io.confluent.kafka.schemaregistry.rules.FieldRuleExecutor

isPrimitive() - Method in enum class io.confluent.kafka.schemaregistry.rules.RuleContext.Type

isPropagateSchemaTags() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

isQualified(String, String) - Static method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Checks if the given subject is qualified with the given tenant.

isRestClientExceptionRetriable(RestClientException) - Static method in class io.confluent.kafka.schemaregistry.client.rest.RestService

isSubjectInContext(String, String, QualifiedSubject) - Static method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Checks if the given qualified subject is a context for the given qualified subject.

isTokenExpired() - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.OauthTokenCache

This method can be used to decide whether we should a network call to OAuth/OIDC provider and get a new token or use existing token in the cache.

isValidateFields() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

isValidateFields() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

isValidateNewSchemas() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

isValidateNewSchemas() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

isValidateRules() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

isValidateRules() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

isValidSubject(String, String) - Static method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Validates the given qualified subject for the given tenant.

isValidSubject(String, String, boolean) - Static method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Validates the given qualified subject for the given tenant.

isValidSubject(String, String, boolean, boolean) - Static method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Validates the given qualified subject for the given tenant, optionally rejecting the empty-string subject.

J

JacksonMapper - Class in io.confluent.kafka.schemaregistry.utils

A utility class wrapping a generic ObjectMapper singleton.

JacksonMapper() - Constructor for class io.confluent.kafka.schemaregistry.utils.JacksonMapper

JSON - Static variable in class io.confluent.kafka.schemaregistry.client.rest.Versions

JSON_WEIGHTED - Static variable in class io.confluent.kafka.schemaregistry.client.rest.Versions

K

KEY_ASSOCIATION_TYPE - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOp

keys() - Method in class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Returns an enumeration of the keys in this table.

keySet() - Method in class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Returns a Set view of the keys contained in this map.

L

LATEST_CACHE_TTL_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

LATEST_CACHE_TTL_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

LENIENT - Enum constant in enum class io.confluent.kafka.schemaregistry.CompatibilityPolicy

LifecyclePolicy - Enum Class in io.confluent.kafka.schemaregistry.client.rest.entities

LifecyclePolicyFilter - Enum Class in io.confluent.kafka.schemaregistry.client.rest.entities

LIRS - Enum constant in enum class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap.Eviction

Deprecated.

LONG - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.RuleContext.Type

lookUpSubjectVersion(RegisterSchemaRequest, String, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

lookUpSubjectVersion(String, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

lookUpSubjectVersion(String, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

lookUpSubjectVersion(String, String, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

lookUpSubjectVersion(String, String, List<SchemaReference>, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

lookUpSubjectVersion(String, String, List<SchemaReference>, String, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

lookUpSubjectVersion(Map<String, String>, RegisterSchemaRequest, String, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

lookUpSubjectVersion(Map<String, String>, RegisterSchemaRequest, String, boolean, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

LRU - Enum constant in enum class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap.Eviction

Deprecated.

M

MAP - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.RuleContext.Type

match(String, String) - Static method in class io.confluent.kafka.schemaregistry.utils.WildcardMatcher

Matches fully-qualified names that use dot (.) as the name boundary.

MAX_BATCH_SIZE - Static variable in interface io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap.EvictionPolicy

Deprecated.

MAX_RETRIES_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

MAX_RETRIES_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

mergeMetadata(Metadata, Metadata) - Static method in class io.confluent.kafka.schemaregistry.client.rest.entities.Metadata

mergeRuleSets(RuleSet, RuleSet) - Static method in class io.confluent.kafka.schemaregistry.client.rest.entities.RuleSet

metadata() - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

metadata() - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns metadata.

Metadata - Class in io.confluent.kafka.schemaregistry.client.rest.entities

Metadata, which includes path annotations, arbitrary key-value properties, and a set of sensitive properties.

Metadata(Map<String, ? extends Set<String>>, Map<String, String>, Set<String>) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Metadata

METADATA_DESC - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

MIGRATION - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.RulePhase

MISSING_CACHE_SIZE_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

MISSING_ID_CACHE_TTL_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

MISSING_SCHEMA_CACHE_TTL_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

MISSING_VERSION_CACHE_TTL_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

MockSchemaRegistry - Class in io.confluent.kafka.schemaregistry.testutil

A repository for mocked Schema Registry clients, to aid in testing.

MockSchemaRegistryClient - Class in io.confluent.kafka.schemaregistry.client

Mock implementation of SchemaRegistryClient that can be used for tests.

MockSchemaRegistryClient() - Constructor for class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

MockSchemaRegistryClient(List<SchemaProvider>) - Constructor for class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

Mode - Class in io.confluent.kafka.schemaregistry.client.rest.entities

Mode(String) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Mode

MODE_DESC - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Mode

ModeUpdateRequest - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

ModeUpdateRequest() - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ModeUpdateRequest

ModeUpdateRequest(String) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ModeUpdateRequest

ModeUpdateRequest(Optional<String>) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ModeUpdateRequest

modifySchemaTags(Map<String, String>, TagSchemaRequest, String, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

mutateAssociations(String, Boolean, AssociationBatchRequest) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

mutateAssociations(String, Boolean, AssociationBatchRequest) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

mutateAssociations(Map<String, String>, String, Boolean, AssociationBatchRequest) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

mutualReadStrategy() - Method in class io.confluent.kafka.schemaregistry.SchemaValidatorBuilder

Use a strategy that validates that a schema can read existing schema(s), and vice-versa, according to the JSON default schema resolution.

N

name - Variable in enum class io.confluent.kafka.schemaregistry.CompatibilityLevel

name - Variable in enum class io.confluent.kafka.schemaregistry.CompatibilityPolicy

name() - Element in annotation interface io.confluent.kafka.schemaregistry.annotations.SchemaReference

name() - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

name() - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns a name for the schema.

NAME_FIELD - Static variable in class io.confluent.kafka.schemaregistry.avro.AvroSchema

NAME_MAX_LENGTH - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Rule

NAME_MAX_LENGTH - Static variable in class io.confluent.kafka.schemaregistry.client.rest.utils.RestValidation

newClient(String, int, List<SchemaProvider>, Map<String, ?>, Map<String, String>) - Static method in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientFactory

newClient(List<String>, int, List<SchemaProvider>, Map<String, ?>, Map<String, String>) - Static method in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientFactory

newObjectMapper() - Static method in class io.confluent.kafka.schemaregistry.utils.JacksonMapper

newTransform(RuleContext) - Method in class io.confluent.kafka.schemaregistry.rules.FieldRedactionExecutor

newTransform(RuleContext) - Method in class io.confluent.kafka.schemaregistry.rules.FieldRuleExecutor

NO_OP_CHECKER - Static variable in class io.confluent.kafka.schemaregistry.CompatibilityChecker

NONE - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.ExecutionEnvironment

NONE - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.LifecyclePolicyFilter

NONE - Enum constant in enum class io.confluent.kafka.schemaregistry.CompatibilityLevel

NONE - Enum constant in enum class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap.Eviction

Deprecated.

NoneAction - Class in io.confluent.kafka.schemaregistry.rules

NoneAction() - Constructor for class io.confluent.kafka.schemaregistry.rules.NoneAction

normalize() - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

normalize() - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns a normalized copy of this schema.

normalize(String, String) - Static method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Normalizes the given qualified subject name.

normalizeContext(String) - Static method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Normalizes the given context name.

NULL - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.RuleContext.Type

NULLABLE - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.RuleContext.Type

O

OauthCredentialProvider - Class in io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth

OAuthCredentialProvider is a BearerAuthCredentialProvider implementation used for configuring OAuth in schema registry.

OauthCredentialProvider() - Constructor for class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.OauthCredentialProvider

OauthTokenCache - Class in io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth

OauthTokenCache is a simple OAuthBearerToken Cache.

OauthTokenCache(short) - Constructor for class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.OauthTokenCache

of(String, String) - Static method in class io.confluent.kafka.schemaregistry.client.rest.entities.ServerClusterId

onEntryChosenForEviction(V) - Method in interface io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap.EvictionListener

Deprecated.

onEntryEviction(Map<K, V>) - Method in interface io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap.EvictionListener

Deprecated.

onEntryHit(BoundedConcurrentHashMap.HashEntry<K, V>) - Method in interface io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap.EvictionPolicy

Deprecated.

Invoked to notify EvictionPolicy implementation that an entry in Segment has been accessed.

onEntryMiss(BoundedConcurrentHashMap.HashEntry<K, V>) - Method in interface io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap.EvictionPolicy

Deprecated.

Invoked to notify EvictionPolicy implementation that there has been an attempt to access an entry in Segment, however that entry was not present in Segment.

onEntryRemove(BoundedConcurrentHashMap.HashEntry<K, V>) - Method in interface io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap.EvictionPolicy

Deprecated.

Invoked to notify EvictionPolicy implementation that an entry e has been removed from Segment.

onKeystoreCreated(KeyStore) - Method in interface io.confluent.kafka.schemaregistry.client.security.SslFactory.SslFactoryCreated

onTruststoreCreated(KeyStore) - Method in interface io.confluent.kafka.schemaregistry.client.security.SslFactory.SslFactoryCreated

opType - Variable in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOp

OpType - Enum Class in io.confluent.kafka.schemaregistry.client.rest.entities

originalKey() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext

originalValue() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext

P

ParsedSchema - Interface in io.confluent.kafka.schemaregistry

A parsed schema.

ParsedSchemaAndValue - Interface in io.confluent.kafka.schemaregistry

A parsed schema with a value.

ParsedSchemaHolder - Interface in io.confluent.kafka.schemaregistry

parseSchema(Schema) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

parseSchema(Schema) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

parseSchema(Schema) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

parseSchema(Schema, boolean) - Method in interface io.confluent.kafka.schemaregistry.SchemaProvider

Parses a schema.

parseSchema(Schema, boolean, boolean) - Method in interface io.confluent.kafka.schemaregistry.SchemaProvider

Parses a schema.

parseSchema(String, String, List<SchemaReference>) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

parseSchema(String, String, List<SchemaReference>) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

parseSchema(String, String, List<SchemaReference>) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

parseSchema(String, String, List<SchemaReference>, Metadata, RuleSet) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

parseSchema(String, List<SchemaReference>) - Method in interface io.confluent.kafka.schemaregistry.SchemaProvider

parseSchema(String, List<SchemaReference>, boolean) - Method in interface io.confluent.kafka.schemaregistry.SchemaProvider

Parses a string representing a schema.

parseSchema(String, List<SchemaReference>, boolean, boolean) - Method in interface io.confluent.kafka.schemaregistry.SchemaProvider

Parses a string representing a schema.

parseSchemaOrElseThrow(Schema) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

parseSchemaOrElseThrow(Schema) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

parseSchemaOrElseThrow(Schema) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

parseSchemaOrElseThrow(Schema, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaProvider

parseSchemaOrElseThrow(Schema, boolean, boolean) - Method in interface io.confluent.kafka.schemaregistry.SchemaProvider

Parses a string representing a schema.

PREFERRED_RESPONSE_TYPES - Static variable in class io.confluent.kafka.schemaregistry.client.rest.Versions

PRESERVE_SOURCE_FIELDS - Static variable in class io.confluent.kafka.schemaregistry.rules.FieldRuleExecutor

PRODUCER - Static variable in class io.confluent.kafka.schemaregistry.rules.DlqAction

PROXY_HOST - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

PROXY_PORT - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

put(K, V) - Method in class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Maps the specified key to the specified value in this table.

putAll(Map<? extends K, ? extends V>) - Method in class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Copies all of the mappings from the specified map to this one.

putIfAbsent(K, V) - Method in class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Q

qualifiedContextFor(String, String) - Static method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Returns the qualified context for the given qualified subject.

QualifiedSubject - Class in io.confluent.kafka.schemaregistry.utils

A qualified subject consists of a tenant, a context, and a subject name.

QualifiedSubject(String, String) - Constructor for class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

QualifiedSubject(String, String, String) - Constructor for class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

qualifySubjectWithParent(String, String, String) - Static method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Qualifies the given subject (which has no tenant) with the given parent context (which may have a tenant).

qualifySubjectWithParent(String, String, String, boolean) - Static method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Qualifies the given subject (which has no tenant) with the given parent context (which may have a tenant).

queryParam(String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.UriBuilder

queryParam(String, Integer) - Method in class io.confluent.kafka.schemaregistry.client.rest.UriBuilder

queryParam(String, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.UriBuilder

R

randomizeIndex() - Method in class io.confluent.kafka.schemaregistry.client.rest.utils.UrlList

RAW_SCHEMA_EXAMPLE - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

rawSchema() - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

rawSchema() - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns the underlying raw representation of the schema.

READ - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.RuleMode

RECORD - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.RuleContext.Type

redactFields(RuleContext, Object, List<String>) - Static method in class io.confluent.kafka.schemaregistry.rules.DlqAction

references() - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

references() - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns a list of schema references.

REFERENCES_DESC - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

refs() - Element in annotation interface io.confluent.kafka.schemaregistry.annotations.Schema

register(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

register(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

register(String, ParsedSchema) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

register(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

register(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

register(String, ParsedSchema, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

register(String, ParsedSchema, int, int) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

register(String, ParsedSchema, int, int) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

register(String, ParsedSchema, int, int) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

register(String, Schema) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

Deprecated.

use SchemaRegistryClient.register(String, ParsedSchema) instead; for example, you can convert a Schema into a ParsedSchema via new AvroSchema(schema)

register(String, Schema, int, int) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

Deprecated.

use SchemaRegistryClient.register(String, ParsedSchema, int, int) instead; for example, you can convert a Schema into a ParsedSchema via new AvroSchema(schema)

registerSchema(RegisterSchemaRequest, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

registerSchema(String, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

registerSchema(String, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

registerSchema(String, String, int, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

registerSchema(String, String, int, int, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

registerSchema(String, String, List<SchemaReference>, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

registerSchema(String, String, List<SchemaReference>, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

registerSchema(String, String, List<SchemaReference>, String, int, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

registerSchema(String, String, List<SchemaReference>, String, int, int, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

registerSchema(Map<String, String>, RegisterSchemaRequest, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

registerSchema(Map<String, String>, RegisterSchemaRequest, String, boolean, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

RegisterSchemaRequest - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

RegisterSchemaRequest() - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

RegisterSchemaRequest(Schema) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

RegisterSchemaRequest(ParsedSchema) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

RegisterSchemaResponse - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

RegisterSchemaResponse() - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

RegisterSchemaResponse(int) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

RegisterSchemaResponse(Schema) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

registerWithResponse(String, ParsedSchema, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

registerWithResponse(String, ParsedSchema, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

registerWithResponse(String, ParsedSchema, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

registerWithResponse(String, ParsedSchema, boolean, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

remove(Object) - Method in class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Removes the key (and its corresponding value) from this map.

remove(Object, Object) - Method in class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

removeConfluentVersion(Metadata) - Static method in class io.confluent.kafka.schemaregistry.client.rest.entities.Metadata

replace(K, V) - Method in class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

replace(K, V, V) - Method in class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

replaceLatestVersion(List<SchemaReference>, SchemaVersionFetcher) - Static method in class io.confluent.kafka.schemaregistry.AbstractSchemaProvider

RESERVED - Static variable in interface io.confluent.kafka.schemaregistry.ParsedSchema

reset() - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

reset() - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

reset() - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

RESOLVED - Enum constant in enum class io.confluent.kafka.schemaregistry.avro.AvroSchema.Format

resolvedReferences() - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

resolveReferences(Schema) - Method in class io.confluent.kafka.schemaregistry.AbstractSchemaProvider

resolveReferences(Schema, boolean) - Method in class io.confluent.kafka.schemaregistry.AbstractSchemaProvider

RestClientException - Exception in io.confluent.kafka.schemaregistry.client.rest.exceptions

RestClientException(String, int, int) - Constructor for exception io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException

RestService - Class in io.confluent.kafka.schemaregistry.client.rest

Rest access layer for sending requests to the schema registry.

RestService(UrlList) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.RestService

RestService(UrlList, boolean) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.RestService

RestService(UrlList, boolean, boolean) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.RestService

RestService(String) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.RestService

RestService(String, boolean) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.RestService

RestService(String, boolean, boolean) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.RestService

RestService(List<String>) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.RestService

RestValidation - Class in io.confluent.kafka.schemaregistry.client.rest.utils

RestValidation() - Constructor for class io.confluent.kafka.schemaregistry.client.rest.utils.RestValidation

RETRIES_MAX_WAIT_MS_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

RETRIES_MAX_WAIT_MS_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

RETRIES_WAIT_MS_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

RETRIES_WAIT_MS_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

retry(Callable<T>) - Method in class io.confluent.kafka.schemaregistry.client.rest.RetryExecutor

RetryExecutor - Class in io.confluent.kafka.schemaregistry.client.rest

RetryExecutor(int, int, int) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.RetryExecutor

RetryExecutor(int, int, int, Random) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.RetryExecutor

rule() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext

Rule - Class in io.confluent.kafka.schemaregistry.client.rest.entities

Rule(String, String, RuleKind, RuleMode, String, Set<String>, Map<String, String>, String, String, String, boolean) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Rule

RULE_EXCEPTION - Static variable in class io.confluent.kafka.schemaregistry.rules.DlqAction

RULE_MODE - Static variable in class io.confluent.kafka.schemaregistry.rules.DlqAction

RULE_NAME - Static variable in class io.confluent.kafka.schemaregistry.rules.DlqAction

RULE_SUBJECT - Static variable in class io.confluent.kafka.schemaregistry.rules.DlqAction

RULE_TOPIC - Static variable in class io.confluent.kafka.schemaregistry.rules.DlqAction

RuleAction - Interface in io.confluent.kafka.schemaregistry.rules

A post-rule action.

RuleBase - Interface in io.confluent.kafka.schemaregistry.rules

Base type for rule interfaces.

RuleClientException - Exception in io.confluent.kafka.schemaregistry.rules

A rule exception that occurs when the client interacts with a remote service.

RuleClientException() - Constructor for exception io.confluent.kafka.schemaregistry.rules.RuleClientException

RuleClientException(Rule, String) - Constructor for exception io.confluent.kafka.schemaregistry.rules.RuleClientException

RuleClientException(Rule, String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.rules.RuleClientException

RuleClientException(Rule, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.rules.RuleClientException

RuleClientException(String) - Constructor for exception io.confluent.kafka.schemaregistry.rules.RuleClientException

RuleClientException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.rules.RuleClientException

RuleClientException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.rules.RuleClientException

RuleConditionException - Exception in io.confluent.kafka.schemaregistry.rules

A schema condition rule exception.

RuleConditionException(Rule) - Constructor for exception io.confluent.kafka.schemaregistry.rules.RuleConditionException

RuleContext - Class in io.confluent.kafka.schemaregistry.rules

A rule context.

RuleContext(Map<String, ?>, ExecutionEnvironment, ParsedSchema, ParsedSchema, String, String, Headers, Object, Object, boolean, RuleMode, Rule, int, List<Rule>) - Constructor for class io.confluent.kafka.schemaregistry.rules.RuleContext

RuleContext.FieldContext - Class in io.confluent.kafka.schemaregistry.rules

RuleContext.Type - Enum Class in io.confluent.kafka.schemaregistry.rules

RuleException - Exception in io.confluent.kafka.schemaregistry.rules

A schema rule exception.

RuleException() - Constructor for exception io.confluent.kafka.schemaregistry.rules.RuleException

RuleException(Rule, String) - Constructor for exception io.confluent.kafka.schemaregistry.rules.RuleException

RuleException(Rule, String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.rules.RuleException

RuleException(Rule, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.rules.RuleException

RuleException(String) - Constructor for exception io.confluent.kafka.schemaregistry.rules.RuleException

RuleException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.rules.RuleException

RuleException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.rules.RuleException

RuleExecutor - Interface in io.confluent.kafka.schemaregistry.rules

A rule executor.

RuleKind - Enum Class in io.confluent.kafka.schemaregistry.client.rest.entities

ruleMode() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext

RuleMode - Enum Class in io.confluent.kafka.schemaregistry.client.rest.entities

RulePhase - Enum Class in io.confluent.kafka.schemaregistry.rules

rules() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext

ruleSet() - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

ruleSet() - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns a rule set.

RuleSet - Class in io.confluent.kafka.schemaregistry.client.rest.entities

Rule set, which includes migration rules (for migrating between versions), domain rules (for business logic), and encoding rules (for encoding logic).

RuleSet(List<Rule>, List<Rule>) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.RuleSet

RuleSet(List<Rule>, List<Rule>, List<Rule>) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.RuleSet

RuleSet(List<Rule>, List<Rule>, List<Rule>, ExecutionEnvironment) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.RuleSet

RULESET_DESC - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

run(RuleContext, Object, RuleException) - Method in class io.confluent.kafka.schemaregistry.rules.DlqAction

run(RuleContext, Object, RuleException) - Method in class io.confluent.kafka.schemaregistry.rules.ErrorAction

run(RuleContext, Object, RuleException) - Method in class io.confluent.kafka.schemaregistry.rules.NoneAction

run(RuleContext, Object, RuleException) - Method in interface io.confluent.kafka.schemaregistry.rules.RuleAction

S

SASL_IDENTITY_POOL_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.SaslOauthCredentialProvider

SaslBasicAuthCredentialProvider - Class in io.confluent.kafka.schemaregistry.client.security.basicauth

SaslBasicAuthCredentialProvider() - Constructor for class io.confluent.kafka.schemaregistry.client.security.basicauth.SaslBasicAuthCredentialProvider

SaslOauthCredentialProvider - Class in io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth

SaslOauthCredentialProvider() - Constructor for class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.SaslOauthCredentialProvider

schema() - Method in interface io.confluent.kafka.schemaregistry.ParsedSchemaHolder

Returns the schema.

schema() - Method in class io.confluent.kafka.schemaregistry.SimpleParsedSchemaHolder

Returns the schema.

Schema - Class in io.confluent.kafka.schemaregistry.client.rest.entities

Schema - Annotation Interface in io.confluent.kafka.schemaregistry.annotations

Specifies the schema for the Java type.

Schema(String, RegisterSchemaRequest) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

Schema(String, RegisterSchemaResponse) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

Schema(String, SchemaMetadata) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

Schema(String, Integer) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

Schema(String, Integer, Integer) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

Schema(String, Integer, Integer, SchemaString) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

Schema(String, Integer, Integer, ParsedSchema) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

Schema(String, Integer, Integer, String, String, List<SchemaReference>, Metadata, RuleSet, String) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

Schema(String, Integer, Integer, String, String, List<SchemaReference>, Metadata, RuleSet, String, List<SchemaTags>, Long, Boolean) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

Schema(String, Integer, Integer, String, List<SchemaReference>, Metadata, RuleSet, String) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

Schema(String, Integer, Integer, String, List<SchemaReference>, String) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

SCHEMA_DESC - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

SCHEMA_EXAMPLE - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

SCHEMA_REGISTRY_DEFAULT_JSON - Static variable in class io.confluent.kafka.schemaregistry.client.rest.Versions

SCHEMA_REGISTRY_DEFAULT_JSON_WEIGHTED - Static variable in class io.confluent.kafka.schemaregistry.client.rest.Versions

SCHEMA_REGISTRY_MOST_SPECIFIC_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.client.rest.Versions

SCHEMA_REGISTRY_USER_INFO_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

Deprecated.

use SchemaRegistryClientConfig.USER_INFO_CONFIG instead

SCHEMA_REGISTRY_V1_JSON - Static variable in class io.confluent.kafka.schemaregistry.client.rest.Versions

SCHEMA_REGISTRY_V1_JSON_WEIGHTED - Static variable in class io.confluent.kafka.schemaregistry.client.rest.Versions

SCHEMA_TAGS_DESC - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

SCHEMA_VERSION_FETCHER_CONFIG - Static variable in interface io.confluent.kafka.schemaregistry.SchemaProvider

SchemaEntity - Class in io.confluent.kafka.schemaregistry.client.rest.entities

SchemaEntity(String, SchemaEntity.EntityType) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaEntity

SchemaEntity.EntityType - Enum Class in io.confluent.kafka.schemaregistry.client.rest.entities

SchemaMetadata - Class in io.confluent.kafka.schemaregistry.client

SchemaMetadata(int, int, String) - Constructor for class io.confluent.kafka.schemaregistry.client.SchemaMetadata

SchemaMetadata(int, int, String, List<SchemaReference>, String) - Constructor for class io.confluent.kafka.schemaregistry.client.SchemaMetadata

SchemaMetadata(Schema) - Constructor for class io.confluent.kafka.schemaregistry.client.SchemaMetadata

SchemaProvider - Interface in io.confluent.kafka.schemaregistry

A factory for parsed schemas.

SchemaReference - Class in io.confluent.kafka.schemaregistry.client.rest.entities

SchemaReference - Annotation Interface in io.confluent.kafka.schemaregistry.annotations

Specifies a schema reference.

SchemaReference(String, String, Integer) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaReference

SchemaRegistryClient - Interface in io.confluent.kafka.schemaregistry.client

SchemaRegistryClientConfig - Class in io.confluent.kafka.schemaregistry.client

SchemaRegistryClientConfig() - Constructor for class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

SchemaRegistryClientFactory - Class in io.confluent.kafka.schemaregistry.client

SchemaRegistryClientFactory() - Constructor for class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientFactory

SchemaRegistryConfigProvider - Class in io.confluent.kafka.schemaregistry.client.config.provider

An implementation of ConfigProvider that obtains configs from metadata in schema registry.

SchemaRegistryConfigProvider() - Constructor for class io.confluent.kafka.schemaregistry.client.config.provider.SchemaRegistryConfigProvider

SchemaRegistryDeployment - Class in io.confluent.kafka.schemaregistry.client.rest.entities

SchemaRegistryDeployment() - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaRegistryDeployment

SchemaRegistryDeployment(String) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaRegistryDeployment

SchemaRegistryDeployment(List<String>) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaRegistryDeployment

SchemaRegistryOauthTokenRetrieverException - Exception in io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.exceptions

SchemaRegistryOauthTokenRetrieverException can be used to differentiate OAuth error/exception of schema registry from that of kafka.

SchemaRegistryOauthTokenRetrieverException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.exceptions.SchemaRegistryOauthTokenRetrieverException

SchemaRegistryServerVersion - Class in io.confluent.kafka.schemaregistry.client.rest.entities

SchemaRegistryServerVersion(String, String) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaRegistryServerVersion

SchemaString - Class in io.confluent.kafka.schemaregistry.client.rest.entities

SchemaString() - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

SchemaString(Schema) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

SchemaString(String) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

SchemaString(String, Integer, Schema) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

SchemaTags - Class in io.confluent.kafka.schemaregistry.client.rest.entities

SchemaTags(SchemaEntity, List<String>) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaTags

schemaTagsListToMap(List<SchemaTags>) - Static method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.TagSchemaRequest

schemaType() - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

schemaType() - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaProvider

schemaType() - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns the schema type.

schemaType() - Method in interface io.confluent.kafka.schemaregistry.SchemaProvider

Returns the schema type.

SchemaValidationStrategy - Interface in io.confluent.kafka.schemaregistry

An interface for validating the compatibility of a single schema against another.

SchemaValidator - Interface in io.confluent.kafka.schemaregistry

A SchemaValidator has one method, which validates that a ParsedSchema is compatible with the other schemas provided.

SchemaValidatorBuilder - Class in io.confluent.kafka.schemaregistry

A Builder for creating SchemaValidators.

SchemaValidatorBuilder() - Constructor for class io.confluent.kafka.schemaregistry.SchemaValidatorBuilder

schemaVersionFetcher() - Method in class io.confluent.kafka.schemaregistry.AbstractSchemaProvider

SchemaVersionFetcher - Interface in io.confluent.kafka.schemaregistry.client

SERVER - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.ExecutionEnvironment

ServerClusterId - Class in io.confluent.kafka.schemaregistry.client.rest.entities

ServerClusterId(Map<String, Object>) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.ServerClusterId

setAlias(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

setAlias(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setAlias(Optional<String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setAliases(List<String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ExtendedSchema

setAliasForDeks(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

setAliasForDeks(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setAliasForDeks(Optional<String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setAssociations(List<? extends AssociationOp>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOpRequest

setAssociations(List<Association>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ExtendedSchema

setAssociations(List<AssociationCreateOrUpdateInfo>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateRequest

setAssociations(List<AssociationInfo>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResponse

setAssociationType(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

setAssociationType(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

setAssociationType(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateOp

setAssociationType(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationDeleteOp

setAssociationType(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationInfo

setAssociationTypes(List<String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationGetRequest

setBasicAuthCredentialProvider(BasicAuthCredentialProvider) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

setBearerAuthCredentialProvider(BearerAuthCredentialProvider) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

setCascadeLifecycle(Boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationDeleteOp

setCommitId(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaRegistryServerVersion

setCompatibilityGroup(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

setCompatibilityGroup(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setCompatibilityGroup(Optional<String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setCompatibilityLevel(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

setCompatibilityLevel(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setCompatibilityLevel(Optional<String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setCompatibilityPolicy(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

setCompatibilityPolicy(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setCompatibilityPolicy(Optional<String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setConfluentVersion(Metadata, int) - Static method in class io.confluent.kafka.schemaregistry.client.rest.entities.Metadata

setContext(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ContextId

setCreateTimestamp(Long) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

setCurrentToken(OAuthBearerToken) - Method in class io.confluent.kafka.schemaregistry.client.security.bearerauth.oauth.OauthTokenCache

This method can be used be to set token right after you fetch the token from the OAuth/OIDC provider.

setDefaultMetadata(Metadata) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

setDefaultMetadata(Metadata) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setDefaultMetadata(Optional<Metadata>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setDefaultRuleSet(RuleSet) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

setDefaultRuleSet(RuleSet) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setDefaultRuleSet(Optional<RuleSet>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setDeleted(Boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

setDeleted(Boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

setDeleted(Boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

setError(ErrorMessage) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOpRequest

setError(ErrorMessage) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResult

setErrorCode(int) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ErrorMessage

setFrozen(boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

setFrozen(boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationInfo

setFrozen(Boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

setFrozen(Boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateOp

setGuid(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

setGuid(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

setGuid(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

setGuid(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

setHostnameVerifier(HostnameVerifier) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

setHttpConnectTimeoutMs(int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

setHttpHeaders(Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

setHttpReadTimeoutMs(int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

setId(int) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

setId(Integer) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ContextId

setId(Integer) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

setId(Integer) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

setIsCompatible(boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.CompatibilityCheckResponse

setLifecycle(LifecyclePolicy) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

setLifecycle(LifecyclePolicy) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

setLifecycle(LifecyclePolicy) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateOp

setLifecycle(LifecyclePolicy) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationGetRequest

setLifecycle(LifecyclePolicy) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationInfo

setMaxId(Integer) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

setMessage(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ErrorMessage

setMessages(List<String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.CompatibilityCheckResponse

setMetadata(Metadata) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

setMetadata(Metadata) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

setMetadata(Metadata) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.TagSchemaRequest

setMetadata(Metadata) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

setMetadata(Metadata) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

setMode(String) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

setMode(String) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

setMode(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Mode

setMode(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ModeUpdateRequest

setMode(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

setMode(String) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

setMode(String, String) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

setMode(String, String) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

setMode(String, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

setMode(String, String) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

setMode(String, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

setMode(String, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

setMode(String, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

setMode(String, String, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

setMode(Map<String, String>, ModeUpdateRequest, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

On success, this api simply echoes the request in the response.

setMode(Optional<String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ModeUpdateRequest

setName(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaReference

setNewVersion(Integer) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.TagSchemaRequest

setNormalize(Boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

setNormalize(Boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

setNormalize(Boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateOp

setNormalize(Boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setNormalize(Optional<Boolean>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setOverrideMetadata(Metadata) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

setOverrideMetadata(Metadata) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setOverrideMetadata(Optional<Metadata>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setOverrideRuleSet(RuleSet) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

setOverrideRuleSet(RuleSet) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setOverrideRuleSet(Optional<RuleSet>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setPropagateSchemaTags(Boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

setProxy(String, int) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

setReferences(List<SchemaReference>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

setReferences(List<SchemaReference>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

setReferences(List<SchemaReference>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

setReferences(List<SchemaReference>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

setRequests(List<AssociationGetRequest>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationBatchGetRequest

setRequests(List<AssociationOpRequest>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationBatchRequest

setResourceId(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

setResourceId(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateRequest

setResourceId(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationGetRequest

setResourceId(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOpRequest

setResourceId(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResponse

setResourceName(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

setResourceName(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateRequest

setResourceName(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationGetRequest

setResourceName(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOpRequest

setResourceName(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResponse

setResourceNamespace(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

setResourceNamespace(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateRequest

setResourceNamespace(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationGetRequest

setResourceNamespace(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOpRequest

setResourceNamespace(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResponse

setResourceType(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

setResourceType(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateRequest

setResourceType(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationGetRequest

setResourceType(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOpRequest

setResourceType(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResponse

setResult(AssociationResponse) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResult

setResults(List<AssociationResult>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationBatchResponse

setRuleSet(RuleSet) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

setRuleSet(RuleSet) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

setRuleSet(RuleSet) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.TagSchemaRequest

setRuleSet(RuleSet) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

setRuleSet(RuleSet) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

setRulesToMerge(RuleSet) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.TagSchemaRequest

setRulesToRemove(List<String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.TagSchemaRequest

setSchema(RegisterSchemaRequest) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

setSchema(RegisterSchemaRequest) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateOp

setSchema(Schema) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationInfo

setSchema(ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.SimpleParsedSchemaHolder

setSchema(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

setSchema(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

setSchema(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

setSchemaEntity(SchemaEntity) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaTags

setSchemaRegistryClient(SchemaRegistryClient) - Method in interface io.confluent.kafka.schemaregistry.rules.RuleBase

setSchemaString(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

setSchemaTags(List<SchemaTags>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

setSchemaTags(List<SchemaTags>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

setSchemaTagsToAdd(List<SchemaTags>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

setSchemaTagsToRemove(List<SchemaTags>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

setSchemaType(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

setSchemaType(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

setSchemaType(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

setSchemaType(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

setSslSocketFactory(SSLSocketFactory) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

setSubject(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

setSubject(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

setSubject(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateOp

setSubject(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationInfo

setSubject(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

setSubject(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaReference

setSubject(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

setSubject(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SubjectVersion

setTags(List<String>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaTags

setTagsToAdd(List<SchemaTags>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.TagSchemaRequest

setTagsToRemove(List<SchemaTags>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.TagSchemaRequest

setThreadLocalData(Schema, boolean, boolean) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

setTimestamp(Long) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

setTimestamp(Long) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

setTimestamp(Long) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

setType(RuleContext.Type) - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext.FieldContext

setUpdateTimestamp(Long) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

setValidateFields(Boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

setValidateFields(Boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setValidateFields(Optional<Boolean>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setValidateNewSchemas(Boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

setValidateNewSchemas(Boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setValidateNewSchemas(Optional<Boolean>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setValidateRules(Boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

setValidateRules(Boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setValidateRules(Optional<Boolean>) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

setVersion(Integer) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

setVersion(Integer) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

setVersion(Integer) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

setVersion(Integer) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaReference

setVersion(Integer) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

setVersion(Integer) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SubjectVersion

setVersion(String) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaRegistryServerVersion

SimpleParsedSchemaHolder - Class in io.confluent.kafka.schemaregistry

SimpleParsedSchemaHolder(ParsedSchema) - Constructor for class io.confluent.kafka.schemaregistry.SimpleParsedSchemaHolder

size() - Method in class io.confluent.kafka.schemaregistry.client.rest.utils.UrlList

The number of unique urls contained in this collection.

size() - Method in class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Returns the number of key-value mappings in this map.

source() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext

SR_FIELD - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaEntity.EntityType

SR_RECORD - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaEntity.EntityType

SSL_PREFIX - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

sslContext() - Method in class io.confluent.kafka.schemaregistry.client.security.SslFactory

Returns a configured SSLContext.

SslFactory - Class in io.confluent.kafka.schemaregistry.client.security

SslFactory(Map<String, ?>) - Constructor for class io.confluent.kafka.schemaregistry.client.security.SslFactory

SslFactory(Map<String, ?>, SslFactory.SslFactoryCreated) - Constructor for class io.confluent.kafka.schemaregistry.client.security.SslFactory

SslFactory.SslFactoryCreated - Interface in io.confluent.kafka.schemaregistry.client.security

Interface to react when keystore or truststore is created, to emit metrics or log events.

StaticTokenCredentialProvider - Class in io.confluent.kafka.schemaregistry.client.security.bearerauth

StaticTokenCredentialProvider() - Constructor for class io.confluent.kafka.schemaregistry.client.security.bearerauth.StaticTokenCredentialProvider

strategy() - Method in interface io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap.EvictionPolicy

Deprecated.

Returns type of eviction algorithm (strategy).

STRICT - Enum constant in enum class io.confluent.kafka.schemaregistry.CompatibilityPolicy

STRING - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.RuleContext.Type

STRONG - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.LifecyclePolicy

STRONG - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.LifecyclePolicyFilter

subject() - Element in annotation interface io.confluent.kafka.schemaregistry.annotations.SchemaReference

subject() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext

SUBJECT_DESC - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

SUBJECT_EXAMPLE - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

SubjectVersion - Class in io.confluent.kafka.schemaregistry.client.rest.entities

SubjectVersion(String, Integer) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.SubjectVersion

symbol() - Method in enum class io.confluent.kafka.schemaregistry.avro.AvroSchema.Format

symbol() - Method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaEntity.EntityType

symbols() - Static method in enum class io.confluent.kafka.schemaregistry.avro.AvroSchema.Format

symbols() - Static method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaEntity.EntityType

T

tags() - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns the set of tags used by the schema.

TAGS - Static variable in class io.confluent.kafka.schemaregistry.avro.AvroSchema

TagSchemaRequest - Class in io.confluent.kafka.schemaregistry.client.rest.entities.requests

TagSchemaRequest() - Constructor for class io.confluent.kafka.schemaregistry.client.rest.entities.requests.TagSchemaRequest

target() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext

tenant() - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

tenant() - Method in interface io.confluent.kafka.schemaregistry.client.SchemaVersionFetcher

TENANT_DELIMITER - Static variable in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

testCompatibility(RegisterSchemaRequest, String, String, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

testCompatibility(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

testCompatibility(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

testCompatibility(String, ParsedSchema) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

testCompatibility(String, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

testCompatibility(String, String, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

testCompatibility(String, String, List<SchemaReference>, String, String, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

testCompatibility(String, Schema) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

Deprecated.

testCompatibility(Map<String, String>, RegisterSchemaRequest, String, String, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

testCompatibilityVerbose(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

testCompatibilityVerbose(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

testCompatibilityVerbose(String, ParsedSchema) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

testCompatibilityVerbose(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

testCompatibilityVerbose(String, ParsedSchema, boolean) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

thresholdExpired() - Method in interface io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap.EvictionPolicy

Deprecated.

Returns true if batching threshold has expired, false otherwise.

ticker() - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

ticker() - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

TIMESTAMP_DESC - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

toAssociationResponse(String, String, String, String, List<Association>, Map<String, Schema>) - Static method in class io.confluent.kafka.schemaregistry.client.rest.entities.Association

toHashKey() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Mode

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationBatchGetRequest

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationBatchRequest

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationBatchResponse

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateRequest

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationGetRequest

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationInfo

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOp

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOpRequest

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResponse

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationResult

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.CompatibilityCheckResponse

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ConfigUpdateRequest

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.ModeUpdateRequest

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.TagSchemaRequest

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaString

toJson() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaTags

toJson(Object) - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

toJson(Object) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

toJson(Object) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

toJson(Object, OutputStream) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

toNormalizedString(AvroSchema) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

toObject(JsonNode, AvroSchema) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

toObject(JsonNode, AvroSchema, DatumReader<Object>) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

toObject(String, AvroSchema) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

toObject(String, AvroSchema, DatumReader<Object>) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

topic() - Method in class io.confluent.kafka.schemaregistry.rules.DlqAction

topic() - Method in class io.confluent.kafka.schemaregistry.rules.RuleContext

toQualifiedContext() - Method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

toQualifiedSubject() - Method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Returns the context and subject with the tenant prefix.

toString() - Method in enum class io.confluent.kafka.schemaregistry.avro.AvroSchema.Format

toString() - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

toString() - Method in class io.confluent.kafka.schemaregistry.avro.Difference

toString() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Config

toString() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ContextId

toString() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.ExtendedSchema

toString() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Metadata

toString() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaRequest

toString() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.RegisterSchemaResponse

toString() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Rule

toString() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.RuleSet

toString() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

toString() - Method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaEntity.EntityType

toString() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaEntity

toString() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaReference

toString() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaTags

toString() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SubjectVersion

toString() - Method in class io.confluent.kafka.schemaregistry.client.rest.UriBuilder

toString() - Method in class io.confluent.kafka.schemaregistry.client.rest.utils.UrlList

toString() - Method in class io.confluent.kafka.schemaregistry.rules.ValidationRule

toString() - Method in class io.confluent.kafka.schemaregistry.rules.ValidationRuleError

toString() - Method in class io.confluent.kafka.schemaregistry.utils.EnumRecommender

toString() - Method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

toUnqualifiedContext() - Method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Returns the context without the tenant prefix.

toUnqualifiedSubject() - Method in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

Returns the context and subject without the tenant prefix.

transform(RuleContext, RuleContext.FieldContext, Object) - Method in class io.confluent.kafka.schemaregistry.rules.FieldRedactionExecutor.FieldRedactionExecutorTransform

transform(RuleContext, RuleContext.FieldContext, Object) - Method in interface io.confluent.kafka.schemaregistry.rules.FieldTransform

transform(RuleContext, Object) - Method in class io.confluent.kafka.schemaregistry.rules.FieldRuleExecutor

transform(RuleContext, Object) - Method in interface io.confluent.kafka.schemaregistry.rules.RuleExecutor

TRANSFORM - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.RuleKind

transformMessage(RuleContext, FieldTransform, Object) - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

transformMessage(RuleContext, FieldTransform, Object) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

type() - Method in class io.confluent.kafka.schemaregistry.rules.DlqAction

type() - Method in class io.confluent.kafka.schemaregistry.rules.ErrorAction

type() - Method in class io.confluent.kafka.schemaregistry.rules.FieldRedactionExecutor

type() - Method in class io.confluent.kafka.schemaregistry.rules.NoneAction

type() - Method in interface io.confluent.kafka.schemaregistry.rules.RuleBase

TYPE - Static variable in class io.confluent.kafka.schemaregistry.avro.AvroSchema

TYPE - Static variable in class io.confluent.kafka.schemaregistry.rules.DlqAction

TYPE - Static variable in class io.confluent.kafka.schemaregistry.rules.ErrorAction

TYPE - Static variable in class io.confluent.kafka.schemaregistry.rules.FieldRedactionExecutor

TYPE - Static variable in class io.confluent.kafka.schemaregistry.rules.NoneAction

TYPE_DESC - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

TYPE_EXAMPLE - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

U

updateCompatibility(String, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

updateCompatibility(String, String) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

updateConfig(ConfigUpdateRequest, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

updateConfig(String, Config) - Method in class io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient

updateConfig(String, Config) - Method in class io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

updateConfig(String, Config) - Method in interface io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

updateConfig(Map<String, String>, ConfigUpdateRequest, String) - Method in class io.confluent.kafka.schemaregistry.client.rest.RestService

On success, this api simply echoes the request in the response.

updateHash(MessageDigest) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Metadata

updateHash(MessageDigest) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Rule

updateHash(MessageDigest) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.RuleSet

updateHash(MessageDigest) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

updateHash(MessageDigest) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaReference

updateHash(MessageDigest, String, List<SchemaReference>, Metadata, RuleSet) - Static method in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

UPDOWN - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.RuleMode

UPGRADE - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.RuleMode

UPSERT - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.OpType

UriBuilder - Class in io.confluent.kafka.schemaregistry.client.rest

UriBuilder(String) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.UriBuilder

URL_RANDOMIZE - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

URL_RANDOMIZE_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

UrlBasicAuthCredentialProvider - Class in io.confluent.kafka.schemaregistry.client.security.basicauth

UrlBasicAuthCredentialProvider() - Constructor for class io.confluent.kafka.schemaregistry.client.security.basicauth.UrlBasicAuthCredentialProvider

UrlList - Class in io.confluent.kafka.schemaregistry.client.rest.utils

This class manages a set of urls for accessing an upstream registry.

UrlList(String) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.utils.UrlList

UrlList(List<String>) - Constructor for class io.confluent.kafka.schemaregistry.client.rest.utils.UrlList

urls() - Method in class io.confluent.kafka.schemaregistry.client.rest.utils.UrlList

USE_APACHE_HTTP_CLIENT - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

USE_APACHE_HTTP_CLIENT_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

useApacheHttpClient(Map<String, ?>) - Static method in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

USER_INFO_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

UserInfoCredentialProvider - Class in io.confluent.kafka.schemaregistry.client.security.basicauth

UserInfoCredentialProvider() - Constructor for class io.confluent.kafka.schemaregistry.client.security.basicauth.UserInfoCredentialProvider

V

validate() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationGetRequest

validate() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.Rule

validate() - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.RuleSet

validate() - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Validates the schema and ensures all references are resolved properly.

validate(boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOp

validate(boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateOp

validate(boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationDeleteOp

validate(boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOp

validate(boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOpRequest

validate(boolean) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Validates the schema and ensures all references are resolved properly.

validate(boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateInfo

validate(boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationCreateOrUpdateRequest

validate(CompatibilityPolicy, ParsedSchema, ParsedSchema) - Method in interface io.confluent.kafka.schemaregistry.SchemaValidationStrategy

Validates that one schema is compatible with another.

validate(CompatibilityPolicy, ParsedSchema, Iterable<ParsedSchemaHolder>) - Method in interface io.confluent.kafka.schemaregistry.SchemaValidator

Validate one schema against others.

validate(ParsedSchema, Iterable<ParsedSchemaHolder>) - Method in interface io.confluent.kafka.schemaregistry.SchemaValidator

validateAll() - Method in class io.confluent.kafka.schemaregistry.SchemaValidatorBuilder

validateAndMaybeGetMockScope(String) - Static method in class io.confluent.kafka.schemaregistry.testutil.MockSchemaRegistry

Deprecated.

validateAndMaybeGetMockScope(List<String>) - Static method in class io.confluent.kafka.schemaregistry.testutil.MockSchemaRegistry

Deprecated.

validateAndMaybeGetMockScopes(String) - Static method in class io.confluent.kafka.schemaregistry.testutil.MockSchemaRegistry

validateAndMaybeGetMockScopes(List<String>) - Static method in class io.confluent.kafka.schemaregistry.testutil.MockSchemaRegistry

validateLatest() - Method in class io.confluent.kafka.schemaregistry.SchemaValidatorBuilder

validateMessage(ValidationRuleExecutor, Object) - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

Walk message against this schema and evaluate every inline confluent:rules CHECK constraint encountered, collecting all failures into the returned list.

validateMessage(ValidationRuleExecutor, Object) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Validate message against the validation rules attached to the schema, returning every failure observed during the walk.

validateMessage(ValidationRuleExecutor, Object, boolean) - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

validateMessage(ValidationRuleExecutor, Object, boolean) - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Validate message against the validation rules attached to the schema.

validateNames(Schema) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils

ValidationRule - Class in io.confluent.kafka.schemaregistry.rules

ValidationRule(String, String, String, String) - Constructor for class io.confluent.kafka.schemaregistry.rules.ValidationRule

ValidationRuleError - Class in io.confluent.kafka.schemaregistry.rules

ValidationRuleError(ValidationRule, String, String, Throwable) - Constructor for class io.confluent.kafka.schemaregistry.rules.ValidationRuleError

ValidationRuleExecutor - Interface in io.confluent.kafka.schemaregistry.rules

validValues(String, Map<String, Object>) - Method in class io.confluent.kafka.schemaregistry.utils.EnumRecommender

value() - Element in annotation interface io.confluent.kafka.schemaregistry.annotations.Schema

VALUE_ASSOCIATION_TYPE - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.requests.AssociationOp

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.avro.AvroSchema.Format

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.ExecutionEnvironment

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.LifecyclePolicy

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.LifecyclePolicyFilter

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.OpType

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.RuleKind

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.RuleMode

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaEntity.EntityType

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.CompatibilityLevel

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.CompatibilityPolicy

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.rules.RuleContext.Type

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.rules.RulePhase

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap.Eviction

Deprecated.

Returns the enum constant of this class with the specified name.

values() - Static method in enum class io.confluent.kafka.schemaregistry.avro.AvroSchema.Format

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.ExecutionEnvironment

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.LifecyclePolicy

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.LifecyclePolicyFilter

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.OpType

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.RuleKind

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.RuleMode

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.schemaregistry.client.rest.entities.SchemaEntity.EntityType

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.schemaregistry.CompatibilityLevel

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.schemaregistry.CompatibilityPolicy

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.schemaregistry.rules.RuleContext.Type

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.schemaregistry.rules.RulePhase

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap.Eviction

Deprecated.

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Method in class io.confluent.kafka.schemaregistry.utils.BoundedConcurrentHashMap

Deprecated.

Returns a Collection view of the values contained in this map.

version() - Element in annotation interface io.confluent.kafka.schemaregistry.annotations.SchemaReference

version() - Method in class io.confluent.kafka.schemaregistry.avro.AvroSchema

version() - Method in interface io.confluent.kafka.schemaregistry.ParsedSchema

Returns the version of the schema if set.

VERSION_8_0 - Static variable in class io.confluent.kafka.schemaregistry.client.rest.RestService

VERSION_DESC - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

VERSION_EXAMPLE - Static variable in class io.confluent.kafka.schemaregistry.client.rest.entities.Schema

Versions - Class in io.confluent.kafka.schemaregistry.client.rest

Versions() - Constructor for class io.confluent.kafka.schemaregistry.client.rest.Versions

visible(String, Map<String, Object>) - Method in class io.confluent.kafka.schemaregistry.utils.EnumRecommender

W

WEAK - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.LifecyclePolicy

WEAK - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.LifecyclePolicyFilter

WILDCARD - Static variable in class io.confluent.kafka.schemaregistry.utils.QualifiedSubject

WildcardMatcher - Class in io.confluent.kafka.schemaregistry.utils

A wildcard matcher.

WildcardMatcher() - Constructor for class io.confluent.kafka.schemaregistry.utils.WildcardMatcher

withClientSslSupport(ConfigDef, String) - Static method in class io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig

WRITE - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.RuleMode

WRITEREAD - Enum constant in enum class io.confluent.kafka.schemaregistry.client.rest.entities.RuleMode

X

X_FORWARD_HEADER - Static variable in class io.confluent.kafka.schemaregistry.client.rest.RestService

A B C D E F G H I J K L M N O P Q R S T U V W X
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form