Index (kafka-schema-registry 8.0.5 API)

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

A

AbstractSchemaRegistry - Class in io.confluent.kafka.schemaregistry.storage: Abstract base class for SchemaRegistry implementations that provides common state management and shared functionality.
AbstractSchemaRegistry(SchemaRegistryConfig, MetricsContainer) - Constructor for class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry: Constructs an AbstractSchemaRegistry with the given configuration.
AbstractSchemaRegistry.RawSchema - Class in io.confluent.kafka.schemaregistry.storage: Internal class representing a raw schema with parsing options.
AbstractSchemaRegistry.SchemeAndPort - Class in io.confluent.kafka.schemaregistry.storage
addCustomHandler(Handler.Singleton) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
addCustomHandler(Handler.Singleton) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
addLeaderChangeListener(Consumer<Boolean>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry: Add a leader change listener.
addLeaderChangeListener(Consumer<Boolean>) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
addSchemaRegistryConfigsToClientProperties(SchemaRegistryConfig, Properties) - Static method in class io.confluent.kafka.schemaregistry.storage.KafkaStore
addSubjectAndVersion(String, int) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaIdAndSubjects
addUpdateRequestHandler(UpdateRequestHandler) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
addUpdateRequestHandler(UpdateRequestHandler) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
addXForwardedForToRequest(MutableRequest, Request) - Method in class io.confluent.kafka.schemaregistry.rest.RequestHeaderHandler
addXRequestIdToRequest(MutableRequest, Response) - Method in class io.confluent.kafka.schemaregistry.rest.RequestHeaderHandler
AliasFilter - Class in io.confluent.kafka.schemaregistry.rest.filters
AliasFilter(SchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.rest.filters.AliasFilter
ALL - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.ExecutionEnvironment
allContexts() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
allowModeChanges - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
allSubjects() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaIdAndSubjects
allSubjectVersions() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaIdAndSubjects
allVersionsIncludingAliasesWithSubjectPrefix(String, LookupFilter, boolean, Predicate<Schema>) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
apiTag - Static variable in class io.confluent.kafka.schemaregistry.rest.resources.AssociationsResource
apiTag - Static variable in class io.confluent.kafka.schemaregistry.rest.resources.CompatibilityResource
apiTag - Static variable in class io.confluent.kafka.schemaregistry.rest.resources.ConfigResource
apiTag - Static variable in class io.confluent.kafka.schemaregistry.rest.resources.ContextsResource
apiTag - Static variable in class io.confluent.kafka.schemaregistry.rest.resources.ModeResource
apiTag - Static variable in class io.confluent.kafka.schemaregistry.rest.resources.SchemasResource
apiTag - Static variable in class io.confluent.kafka.schemaregistry.rest.resources.ServerMetadataResource
apiTag - Static variable in class io.confluent.kafka.schemaregistry.rest.resources.SubjectsResource
apiTag - Static variable in class io.confluent.kafka.schemaregistry.rest.resources.SubjectVersionsResource
AppInfoParser - Class in io.confluent.kafka.schemaregistry.utils
AppInfoParser() - Constructor for class io.confluent.kafka.schemaregistry.utils.AppInfoParser
aroundWriteTo(WriterInterceptorContext) - Method in class io.confluent.kafka.schemaregistry.rest.exceptions.JettyEofExceptionWriterInterceptor
ASSOC - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKeyType
ASSOCIATION_FOR_RESOURCE_EXISTS_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
ASSOCIATION_FOR_RESOURCE_EXISTS_MESSAGE_FORMAT - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
ASSOCIATION_FOR_SUBJECT_EXISTS_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
ASSOCIATION_FOR_SUBJECT_EXISTS_MESSAGE_FORMAT - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
ASSOCIATION_FROZEN_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
ASSOCIATION_FROZEN_MESSAGE_FORMAT - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
ASSOCIATION_NOT_FOUND_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
ASSOCIATION_NOT_FOUND_MESSAGE_FORMAT - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
associationByGuid(String) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
associationByGuid(String) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Returns the association for the given association guid.
associationForResourceExistsException(String, String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
AssociationForResourceExistsException - Exception in io.confluent.kafka.schemaregistry.exceptions
AssociationForResourceExistsException(String, String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.AssociationForResourceExistsException
associationForSubjectExistsException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
AssociationForSubjectExistsException - Exception in io.confluent.kafka.schemaregistry.exceptions
AssociationForSubjectExistsException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.AssociationForSubjectExistsException
AssociationForSubjectExistsException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.AssociationForSubjectExistsException
AssociationForSubjectExistsException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.AssociationForSubjectExistsException
AssociationForSubjectExistsException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.AssociationForSubjectExistsException
associationFrozenException(String, String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
AssociationFrozenException - Exception in io.confluent.kafka.schemaregistry.exceptions
AssociationFrozenException(String, String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.AssociationFrozenException
AssociationKey - Class in io.confluent.kafka.schemaregistry.storage
AssociationKey(String, String, String, String, String, String) - Constructor for class io.confluent.kafka.schemaregistry.storage.AssociationKey
associationNotFoundException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
AssociationNotFoundException - Exception in io.confluent.kafka.schemaregistry.exceptions
AssociationNotFoundException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.AssociationNotFoundException
AssociationNotFoundException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.AssociationNotFoundException
AssociationNotFoundException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.AssociationNotFoundException
AssociationNotFoundException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.AssociationNotFoundException
associationRegistered(AssociationKey, AssociationValue, AssociationValue) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
associationRegistered(AssociationKey, AssociationValue, AssociationValue) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Callback that is invoked when an association is registered.
ASSOCIATIONS_ENABLE - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: associations.enable*
ASSOCIATIONS_ENABLE_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
associationsByResourceId(String) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
associationsByResourceId(String) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Returns associations for the given resource id.
associationsBySubject(String) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
associationsBySubject(String) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Returns associations for the given subject.
AssociationsResource - Class in io.confluent.kafka.schemaregistry.rest.resources
AssociationsResource(SchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.rest.resources.AssociationsResource
associationTombstoned(AssociationKey, AssociationValue) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
associationTombstoned(AssociationKey, AssociationValue) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Callback that is invoked when an association is tombstoned.
AssociationValue - Class in io.confluent.kafka.schemaregistry.storage
AssociationValue(String, String, String, String, String, String, String, String, Lifecycle, boolean, Long) - Constructor for class io.confluent.kafka.schemaregistry.storage.AssociationValue
AvroUtils - Class in io.confluent.kafka.schemaregistry.avro
AvroUtils() - Constructor for class io.confluent.kafka.schemaregistry.avro.AvroUtils
awaitShutdown() - Method in class io.confluent.kafka.schemaregistry.utils.ShutdownableThread: After calling initiateShutdown(), use this API to wait until the shutdown is complete.

B

base() - Method in class io.confluent.kafka.schemaregistry.id.SchemaIdRange
baseDir(String, String) - Method in class io.confluent.kafka.schemaregistry.storage.OffsetCheckpoint
baseSchemaRegistryConfigDef() - Static method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
bootstrapBrokers() - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
build() - Method in class otherns.Subrecord.Builder
buildRequestHeaders(HttpHeaders, List<String>) - Method in class io.confluent.kafka.schemaregistry.rest.resources.RequestHeaderBuilder
bytes() - Method in class io.confluent.kafka.schemaregistry.storage.MD5

C

cacheInitialized(Map<TopicPartition, Long>) - Method in class io.confluent.kafka.schemaregistry.storage.CompositeSchemaUpdateHandler: Invoked after the cache is initialized.
cacheInitialized(Map<TopicPartition, Long>) - Method in interface io.confluent.kafka.schemaregistry.storage.StoreUpdateHandler: Invoked after the cache is initialized.
canonicalize(SchemaProvider, SchemaValue) - Static method in class io.confluent.kafka.schemaregistry.storage.KafkaStoreMessageHandler
canonicalizeSchema(Schema, Config, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
checkBootstrapServers() - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
checkIfSchemaWithIdExist(int, Schema) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
checkpoint(int) - Method in class io.confluent.kafka.schemaregistry.storage.CompositeSchemaUpdateHandler
checkpoint(int) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStoreMessageHandler
checkpoint(int) - Method in interface io.confluent.kafka.schemaregistry.storage.StoreUpdateHandler: Retrieve the offsets to checkpoint.
CHECKPOINT_FILE_NAME - Static variable in class io.confluent.kafka.schemaregistry.storage.OffsetCheckpoint
checkpoints() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStoreReaderThread
checkRegisterMode(String, Schema) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
clear() - Method in class io.confluent.kafka.schemaregistry.storage.LazyParsedSchemaHolder: Clears the schema if it can be lazily retrieved in the future.
CLEAR_SUBJECT - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKeyType
clearField2() - Method in class otherns.Subrecord.Builder: Clears the value of the 'field2' field.
clearNewSchemaCache() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
clearNewSchemaCache() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
clearOldSchemaCache() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
clearOldSchemaCache() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
ClearSubjectKey - Class in io.confluent.kafka.schemaregistry.storage
ClearSubjectKey(String) - Constructor for class io.confluent.kafka.schemaregistry.storage.ClearSubjectKey
clearSubjects(String) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
clearSubjects(String) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Clears the cache of deleted schemas that match the given subject.
ClearSubjectValue - Class in io.confluent.kafka.schemaregistry.storage
ClearSubjectValue(String) - Constructor for class io.confluent.kafka.schemaregistry.storage.ClearSubjectValue
CLIENT - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.ExecutionEnvironment
close() - Method in class io.confluent.kafka.schemaregistry.leaderelector.kafka.KafkaGroupLeaderElector
close() - Method in interface io.confluent.kafka.schemaregistry.storage.CloseableIterator
close() - Method in class io.confluent.kafka.schemaregistry.storage.CompositeSchemaUpdateHandler
close() - Method in class io.confluent.kafka.schemaregistry.storage.encoder.KafkaMetadataEncoderService
close() - Method in class io.confluent.kafka.schemaregistry.storage.encoder.KeysetWrapperSerde
close() - Method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService
close() - Method in class io.confluent.kafka.schemaregistry.storage.FilteredIterator
close() - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
close() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
close() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore
close() - Method in interface io.confluent.kafka.schemaregistry.storage.LeaderElector
close() - Method in class io.confluent.kafka.schemaregistry.storage.OffsetCheckpoint
close() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
close() - Method in class io.confluent.kafka.schemaregistry.storage.serialization.SchemaRegistrySerializer
close() - Method in interface io.confluent.kafka.schemaregistry.storage.serialization.Serializer: Close this serializer
close() - Method in interface io.confluent.kafka.schemaregistry.storage.Store
close() - Method in interface io.confluent.kafka.schemaregistry.storage.StoreUpdateHandler
close() - Method in class io.confluent.kafka.schemaregistry.storage.TransformedIterator
close() - Method in class io.confluent.kafka.schemaregistry.tools.SchemaRegistryClientPerformance
close() - Method in class io.confluent.kafka.schemaregistry.tools.SchemaRegistryPerformance
CloseableIterator<T> - Interface in io.confluent.kafka.schemaregistry.storage
compare(K, K) - Method in class io.confluent.kafka.schemaregistry.storage.SubjectKeyComparator
compareTo(SchemaReference) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaReference
compareTo(SchemaRegistryKey) - Method in class io.confluent.kafka.schemaregistry.storage.AssociationKey
compareTo(SchemaRegistryKey) - Method in class io.confluent.kafka.schemaregistry.storage.ContextKey
compareTo(SchemaRegistryKey) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaKey
compareTo(SchemaRegistryKey) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKey
compareTo(SchemaRegistryKey) - Method in class io.confluent.kafka.schemaregistry.storage.SubjectKey
compareTo(SchemaValue) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
COMPATIBILITY_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: Deprecated.
COMPATIBILITY_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
compatibilityLevel(String, boolean, CompatibilityLevel) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Retrieves the config for a subject.
CompatibilityResource - Class in io.confluent.kafka.schemaregistry.rest.resources
CompatibilityResource(SchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.rest.resources.CompatibilityResource
compatibilityType() - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
CompositeSchemaUpdateHandler - Class in io.confluent.kafka.schemaregistry.storage
CompositeSchemaUpdateHandler(List<SchemaUpdateHandler>) - Constructor for class io.confluent.kafka.schemaregistry.storage.CompositeSchemaUpdateHandler
CompositeUpdateRequestHandler - Class in io.confluent.kafka.schemaregistry.rest.handlers
CompositeUpdateRequestHandler(List<UpdateRequestHandler>) - Constructor for class io.confluent.kafka.schemaregistry.rest.handlers.CompositeUpdateRequestHandler
CONDITION - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.RuleKind
config - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
config() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
config() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
config(String, boolean, Config) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
config(String, boolean, Config) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Retrieves the config for a subject.
CONFIG - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKeyType
ConfigKey - Class in io.confluent.kafka.schemaregistry.storage
ConfigKey(String) - Constructor for class io.confluent.kafka.schemaregistry.storage.ConfigKey
ConfigResource - Class in io.confluent.kafka.schemaregistry.rest.resources
ConfigResource(SchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.rest.resources.ConfigResource
configure(SchemaRegistryConfig) - Method in interface io.confluent.kafka.schemaregistry.id.IdGenerator: Configure the underlying generator.
configure(SchemaRegistryConfig) - Method in class io.confluent.kafka.schemaregistry.id.IncrementalIdGenerator
configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.storage.serialization.SchemaRegistrySerializer
configure(Map<String, ?>) - Method in interface io.confluent.kafka.schemaregistry.storage.StoreUpdateHandler
configure(Map<String, ?>, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.encoder.KeysetWrapperSerde
configureBaseApplication(Configurable<?>, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication
configurePreResourceHandling(ServletContextHandler) - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication
ConfigValue - Class in io.confluent.kafka.schemaregistry.storage
ConfigValue(String, Config) - Constructor for class io.confluent.kafka.schemaregistry.storage.ConfigValue
ConfigValue(String, Config, RuleSetHandler) - Constructor for class io.confluent.kafka.schemaregistry.storage.ConfigValue
ConfigValue(String, CompatibilityLevel) - Constructor for class io.confluent.kafka.schemaregistry.storage.ConfigValue
ConfigValue(String, String, String, Boolean, Boolean, Boolean, Boolean, CompatibilityLevel, CompatibilityPolicy, String, Metadata, Metadata, RuleSet, RuleSet) - Constructor for class io.confluent.kafka.schemaregistry.storage.ConfigValue
containsSchema(Schema) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
containsSchema(Schema) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Checks if a schema is registered in any subject.
CONTEXT - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKeyType
CONTEXT_NOT_EMPTY_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
CONTEXT_SEARCH_DEFAULT_LIMIT_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: context.search.default.limit
CONTEXT_SEARCH_DEFAULT_LIMIT_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
CONTEXT_SEARCH_DEFAULT_LIMIT_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
CONTEXT_SEARCH_MAX_LIMIT_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: context.search.max.limit
CONTEXT_SEARCH_MAX_LIMIT_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
CONTEXT_SEARCH_MAX_LIMIT_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
ContextFilter - Class in io.confluent.kafka.schemaregistry.rest.filters
ContextFilter() - Constructor for class io.confluent.kafka.schemaregistry.rest.filters.ContextFilter
ContextKey - Class in io.confluent.kafka.schemaregistry.storage
ContextKey(String, String) - Constructor for class io.confluent.kafka.schemaregistry.storage.ContextKey
contextNotEmptyException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
contextSearchDefaultLimit - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
contextSearchMaxLimit - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
ContextsResource - Class in io.confluent.kafka.schemaregistry.rest.resources
ContextsResource(SchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.rest.resources.ContextsResource
ContextValue - Class in io.confluent.kafka.schemaregistry.storage
ContextValue(String, String) - Constructor for class io.confluent.kafka.schemaregistry.storage.ContextValue
createAssociation(AsyncResponse, HttpHeaders, String, boolean, AssociationCreateOrUpdateRequest) - Method in class io.confluent.kafka.schemaregistry.rest.resources.AssociationsResource
createAssociation(String, boolean, AssociationCreateOrUpdateRequest) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
createAssociation(String, boolean, AssociationCreateOrUpdateRequest) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
createAssociationOrForward(String, boolean, AssociationCreateOrUpdateRequest, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
createAssociationOrForward(String, boolean, AssociationCreateOrUpdateRequest, Map<String, String>) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
createCache(Serde<K>, Serde<V>, String, CacheUpdateHandler<K, V>) - Method in class io.confluent.kafka.schemaregistry.storage.encoder.KafkaMetadataEncoderService
createDecoder(SchemaStore) - Static method in class otherns.Subrecord: Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore.
createOrUpdateAssociation(AsyncResponse, HttpHeaders, String, String, boolean, AssociationCreateOrUpdateRequest) - Method in class io.confluent.kafka.schemaregistry.rest.resources.AssociationsResource
createOrUpdateAssociation(String, boolean, AssociationCreateOrUpdateRequest) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
createOrUpdateAssociation(String, boolean, AssociationCreateOrUpdateRequest) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
createOrUpdateAssociation(String, boolean, AssociationCreateOrUpdateRequest, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
createOrUpdateAssociationOrForward(String, boolean, AssociationCreateOrUpdateRequest, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
createOrUpdateAssociationOrForward(String, boolean, AssociationCreateOrUpdateRequest, Map<String, String>) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
CURRENT_VERSION - Static variable in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
customDecode(ResolvingDecoder) - Method in class otherns.Subrecord
customEncode(Encoder) - Method in class otherns.Subrecord
customHandler - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry

D

decodeMetadata(SchemaValue) - Method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService
DEFAULT - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.LookupFilter
DEFAULT_ASSOCIATIONS_ENABLE - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
DEFAULT_ENABLE_STORE_HEALTH_CHECK - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
DEFAULT_ERROR_CODE - Static variable in exception io.confluent.kafka.schemaregistry.rest.exceptions.RestConflictException
DEFAULT_ERROR_CODE - Static variable in exception io.confluent.kafka.schemaregistry.rest.exceptions.RestIncompatibleSchemaException
DEFAULT_KAFKASTORE_TOPIC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
DEFAULT_KAFKASTORE_TOPIC_REPLICATION_FACTOR - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
DEFAULT_KAFKASTORE_TOPIC_SKIP_VALIDATION - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
DEFAULT_KAFKASTORE_WRITE_MAX_RETRIES - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
DEFAULT_LEADER_CONNECT_TIMEOUT_MS - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
DEFAULT_LEADER_ELECTION_DELAY - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
DEFAULT_LEADER_ELECTION_STICKY - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
DEFAULT_LEADER_ELIGIBILITY - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
DEFAULT_LEADER_READ_TIMEOUT_MS - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
DEFAULT_MODE_MUTABILITY - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
DEFAULT_RESOURCE_TYPE - Static variable in class io.confluent.kafka.schemaregistry.rest.resources.AssociationsResource
DEFAULT_TENANT - Static variable in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
defaultCompatibilityLevel - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
defaultMode - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
defaultValidateFields - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
defaultValidateNewSchemas - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
definedResourceExtensionConfigName() - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: Gets the name of the config that contains resource extension classes, handling deprecated config names.
delete() - Method in class io.confluent.kafka.schemaregistry.storage.OffsetCheckpoint
delete(K) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
delete(K) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore
delete(K) - Method in interface io.confluent.kafka.schemaregistry.storage.Store
DELETE_SUBJECT - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKeyType
deleteAssociations(AsyncResponse, HttpHeaders, String, String, List<String>, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.AssociationsResource
deleteAssociations(String, String, List<String>, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
deleteAssociations(String, String, List<String>, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
deleteAssociationsOrForward(String, String, String, List<String>, boolean, boolean, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
deleteAssociationsOrForward(String, String, String, List<String>, boolean, boolean, Map<String, String>) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
deleteConfig(String) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
deleteConfigOrForward(String, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
deleteConfigOrForward(String, Map<String, String>) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
deleteContext(AsyncResponse, HttpHeaders, String) - Method in class io.confluent.kafka.schemaregistry.rest.resources.ContextsResource
deleteContext(String) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
deleteContext(String) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
deleteContextOrForward(Map<String, String>, String) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
deleteContextOrForward(Map<String, String>, String) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
DELETED_ONLY - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.LookupFilter
deleteGlobalMode(AsyncResponse, HttpHeaders, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.ModeResource
deleteSchemaVersion(AsyncResponse, HttpHeaders, String, String, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SubjectVersionsResource
deleteSchemaVersion(String, Schema, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
deleteSchemaVersion(String, Schema, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
deleteSchemaVersion(String, String, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
deleteSchemaVersion(Map<String, String>, String, String, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
deleteSchemaVersionOrForward(Map<String, String>, String, Schema, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
deleteSchemaVersionOrForward(Map<String, String>, String, Schema, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
deleteSubject(AsyncResponse, HttpHeaders, String, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SubjectsResource
deleteSubject(String, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
deleteSubject(String, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
deleteSubject(String, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
deleteSubject(Map<String, String>, String, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
deleteSubjectConfig(AsyncResponse, HttpHeaders, String) - Method in class io.confluent.kafka.schemaregistry.rest.resources.ConfigResource
deleteSubjectConfig(String) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
deleteSubjectConfig(String) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
DeleteSubjectKey - Class in io.confluent.kafka.schemaregistry.storage
DeleteSubjectKey(String) - Constructor for class io.confluent.kafka.schemaregistry.storage.DeleteSubjectKey
deleteSubjectMode(AsyncResponse, HttpHeaders, String, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.ModeResource
deleteSubjectMode(String) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
deleteSubjectMode(String) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
deleteSubjectMode(String, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
deleteSubjectMode(String, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
deleteSubjectModeOrForward(String, boolean, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
deleteSubjectModeOrForward(String, boolean, Map<String, String>) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
deleteSubjectOrForward(Map<String, String>, String, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
deleteSubjectOrForward(Map<String, String>, String, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
DeleteSubjectValue - Class in io.confluent.kafka.schemaregistry.storage
DeleteSubjectValue(String, Integer) - Constructor for class io.confluent.kafka.schemaregistry.storage.DeleteSubjectValue
deleteTopLevelConfig(AsyncResponse, HttpHeaders) - Method in class io.confluent.kafka.schemaregistry.rest.resources.ConfigResource
deserialize(String, byte[]) - Method in class io.confluent.kafka.schemaregistry.storage.encoder.KeysetWrapperDeserializer
deserializeKey(byte[]) - Method in class io.confluent.kafka.schemaregistry.storage.serialization.SchemaRegistrySerializer
deserializeKey(byte[]) - Method in interface io.confluent.kafka.schemaregistry.storage.serialization.Serializer
deserializer() - Method in class io.confluent.kafka.schemaregistry.storage.encoder.KeysetWrapperSerde
deserializeValue(SchemaRegistryKey, byte[]) - Method in class io.confluent.kafka.schemaregistry.storage.serialization.SchemaRegistrySerializer
deserializeValue(K, byte[]) - Method in interface io.confluent.kafka.schemaregistry.storage.serialization.Serializer
DocumentedName - Annotation Interface in io.confluent.kafka.schemaregistry.rest.resources
doInit() - Method in class io.confluent.kafka.schemaregistry.storage.encoder.KafkaMetadataEncoderService
doInit() - Method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService: Subclass hook to prepare any resources before secret rotation occurs.
doIteration(PerformanceStats.Callback) - Method in class io.confluent.kafka.schemaregistry.tools.SchemaRegistryClientPerformance
doIteration(PerformanceStats.Callback) - Method in class io.confluent.kafka.schemaregistry.tools.SchemaRegistryPerformance
DOWNGRADE - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.RuleMode
doWork() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStoreReaderThread
doWork() - Method in class io.confluent.kafka.schemaregistry.utils.ShutdownableThread: This method is repeatedly invoked until the thread shuts down or this method throws an exception

E

emitCertificateExpirationMetric(KeyStore, SchemaRegistryMetric) - Method in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
ENABLE_FIPS_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
ENABLE_FIPS_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
ENABLE_STORE_HEALTH_CHECK - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
ENABLE_STORE_HEALTH_CHECK_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
enableAssociations() - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
ENCODED_PROPERTY - Static variable in class io.confluent.kafka.schemaregistry.storage.SchemaValue
encodeMetadata(SchemaValue) - Method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService
encoderOldSecret(SchemaRegistryConfig) - Static method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService
encoders - Variable in class io.confluent.kafka.schemaregistry.storage.encoder.KafkaMetadataEncoderService
encoderSecret - Variable in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService
encoderSecret(SchemaRegistryConfig) - Static method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService
end() - Method in class io.confluent.kafka.schemaregistry.id.SchemaIdRange
endBatch(int) - Method in class io.confluent.kafka.schemaregistry.storage.CompositeSchemaUpdateHandler
endBatch(int) - Method in interface io.confluent.kafka.schemaregistry.storage.StoreUpdateHandler: Invoked after a batch of updates.
EntryTooLargeException - Exception in io.confluent.kafka.schemaregistry.storage.exceptions
EntryTooLargeException(String) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.EntryTooLargeException
EntryTooLargeException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.EntryTooLargeException
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry.RawSchema
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.AssociationKey
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.ClearSubjectKey
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.ClearSubjectValue
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.ConfigKey
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.ContextKey
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.ContextValue
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.DeleteSubjectKey
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.DeleteSubjectValue
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.MD5
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.Metadata
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.ModeKey
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.ModeValue
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.NoopKey
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.Rule
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.RuleSet
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaIdAndSubjects
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaKey
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaReference
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKey
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.SubjectKey
equals(Object) - Method in class io.confluent.kafka.schemaregistry.storage.SubjectValue
equals(Object) - Method in class otherns.Subrecord
ERROR_CODE - Static variable in exception io.confluent.kafka.schemaregistry.rest.exceptions.RestContextNotEmptyException
ERROR_CODE - Static variable in exception io.confluent.kafka.schemaregistry.rest.exceptions.RestIdDoesNotMatchException
ERROR_CODE - Static variable in exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidAssociationException
ERROR_CODE - Static variable in exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidCompatibilityException
ERROR_CODE - Static variable in exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidModeException
ERROR_CODE - Static variable in exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidRuleSetException
ERROR_CODE - Static variable in exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidSchemaException
ERROR_CODE - Static variable in exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidSubjectException
ERROR_CODE - Static variable in exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidVersionException
ERROR_CODE - Static variable in exception io.confluent.kafka.schemaregistry.rest.exceptions.RestReferenceExistsException
Errors - Class in io.confluent.kafka.schemaregistry.rest.exceptions
Errors() - Constructor for class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
ExecutionEnvironment - Enum Class in io.confluent.kafka.schemaregistry.storage
extractSchemaTags(Schema, List<String>) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
extractSchemaTags(Schema, List<String>) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry

F

FIELD_CONFLICTS_WITH_RESERVED_FIELD - Static variable in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
file - Variable in class io.confluent.kafka.schemaregistry.storage.OffsetCheckpoint
filter(CloseableIterator<T>, Predicate<? super T>) - Static method in class io.confluent.kafka.schemaregistry.storage.FilteredIterator
filter(ContainerRequestContext) - Method in class io.confluent.kafka.schemaregistry.rest.filters.AliasFilter
filter(ContainerRequestContext) - Method in class io.confluent.kafka.schemaregistry.rest.filters.ContextFilter
filter(ContainerRequestContext, ContainerResponseContext) - Method in class io.confluent.kafka.schemaregistry.rest.filters.RestCallMetricFilter
FilteredIterator<T> - Class in io.confluent.kafka.schemaregistry.storage
findAny(Predicate<SchemaKey>) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaIdAndSubjects
finished(int) - Method in class io.confluent.kafka.schemaregistry.tools.SchemaRegistryPerformance
flush() - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
flush() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore
flush() - Method in interface io.confluent.kafka.schemaregistry.storage.Store
forName(String) - Static method in enum class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKeyType
forwardModifySchemaTagsRequestToLeader(String, Schema, TagSchemaRequest, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
fromAssociationCreateOrUpdateRequest(String, AssociationCreateOrUpdateRequest, List<Association>, Set<String>) - Static method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
fromByteBuffer(ByteBuffer) - Static method in class otherns.Subrecord: Deserializes a Subrecord from a ByteBuffer.
fromEntity(ExecutionEnvironment) - Static method in enum class io.confluent.kafka.schemaregistry.storage.ExecutionEnvironment
fromEntity(RuleKind) - Static method in enum class io.confluent.kafka.schemaregistry.storage.RuleKind
fromEntity(RuleMode) - Static method in enum class io.confluent.kafka.schemaregistry.storage.RuleMode
fromJson(String) - Static method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
fromJson(ByteBuffer) - Static method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
fromString(String) - Static method in class io.confluent.kafka.schemaregistry.storage.MD5

G

GATEWAY - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.ExecutionEnvironment
generateAcceptableResponse(Request, Response, Callback, String, List<Charset>, int, String, Throwable) - Method in class io.confluent.kafka.schemaregistry.rest.JsonErrorHandler
get() - Method in class io.confluent.kafka.schemaregistry.rest.resources.RootResource
get(int) - Method in class otherns.Subrecord
get(int, String) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
get(int, String) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
get(int, String, String, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
get(int, String, String, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
get(String, int, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
get(String, int, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
get(K) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
get(K) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore
get(K) - Method in interface io.confluent.kafka.schemaregistry.storage.Store
getAlias() - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
getAliasForDeks() - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
getAll(K, K) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
getAll(K, K) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore
getAll(K, K) - Method in interface io.confluent.kafka.schemaregistry.storage.Store: Iterator over keys in the specified range
getAllKeys() - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
getAllKeys() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore
getAllKeys() - Method in interface io.confluent.kafka.schemaregistry.storage.Store
getAllSchemaKeysDescending(String) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getAllSubjects() - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getAllSubjectsById(int) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getAllTenants() - Method in class io.confluent.kafka.schemaregistry.storage.encoder.KafkaMetadataEncoderService
getAllTenants() - Method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService: Get all tenant keys.
getAllVersions(String) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getAllVersions(String, LookupFilter) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getAllVersions(String, LookupFilter) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getAllVersionsById(int) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getApiCallsFailure() - Method in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
getApiCallsSuccess() - Method in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
getAssociationByGuid(String) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
getAssociationByGuid(String) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getAssociationsByResourceId(String, String, List<String>, LifecyclePolicy) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
getAssociationsByResourceId(String, String, List<String>, LifecyclePolicy) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getAssociationsByResourceId(String, String, List<String>, LifecyclePolicy, int, int) - Method in class io.confluent.kafka.schemaregistry.rest.resources.AssociationsResource
getAssociationsByResourceName(String, String, String, List<String>, LifecyclePolicy) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
getAssociationsByResourceName(String, String, String, List<String>, LifecyclePolicy) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getAssociationsByResourceName(String, String, String, List<String>, LifecyclePolicy, int, int) - Method in class io.confluent.kafka.schemaregistry.rest.resources.AssociationsResource
getAssociationsBySubject(String, String, List<String>, LifecyclePolicy) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
getAssociationsBySubject(String, String, List<String>, LifecyclePolicy) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getAssociationsBySubject(String, String, List<String>, LifecyclePolicy, int, int) - Method in class io.confluent.kafka.schemaregistry.rest.resources.AssociationsResource
getAssociationType() - Method in exception io.confluent.kafka.schemaregistry.exceptions.AssociationForResourceExistsException
getAssociationType() - Method in exception io.confluent.kafka.schemaregistry.exceptions.AssociationFrozenException
getAssociationType() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationKey
getAssociationType() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
getByGuid(String, String) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getByGuid(String, String) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getByVersion(String, int, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getByVersion(String, int, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getCertificateExpirationKeystore() - Method in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
getCertificateExpirationTruststore() - Method in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
getClassSchema() - Static method in class otherns.Subrecord
getClusterId() - Method in class io.confluent.kafka.schemaregistry.rest.resources.ServerMetadataResource
getCommitId() - Static method in class io.confluent.kafka.schemaregistry.utils.AppInfoParser
getCompatibilityGroup() - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
getCompatibilityLevel() - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
getCompatibilityPolicy() - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
getCompositeUpdateRequestHandler() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getCompositeUpdateRequestHandler() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getConfig(String) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getConfig(String) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getConfig(String) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getConfigInScope(String) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getConfigInScope(String) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getConsumerProperty(String) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStoreReaderThread
getContext() - Method in class io.confluent.kafka.schemaregistry.storage.ContextKey
getContext() - Method in class io.confluent.kafka.schemaregistry.storage.ContextValue
getContextPrefixForDeleteMode(String) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry: Returns the context prefix to use for listing subjects under a given context.
getCreateTimestamp() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
getCurrentVersion() - Static method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
getCustomHandler() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getCustomHandler() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getCustomSchemaProviderCount() - Method in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
getDecoder() - Static method in class otherns.Subrecord: Return the BinaryMessageDecoder instance used by this class.
getDefaultMetadata() - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
getDefaultRuleSet() - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
getDoc() - Method in class io.confluent.kafka.schemaregistry.storage.Rule
getDomainRules() - Method in class io.confluent.kafka.schemaregistry.storage.RuleSet
getEnableOnlyAt() - Method in class io.confluent.kafka.schemaregistry.storage.RuleSet
getEncoder() - Static method in class otherns.Subrecord: Return the BinaryMessageEncoder instance used by this class.
getEncoder(String) - Method in class io.confluent.kafka.schemaregistry.storage.encoder.KafkaMetadataEncoderService
getEncoder(String) - Method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService
getEncoderWrapper(String) - Method in class io.confluent.kafka.schemaregistry.storage.encoder.KafkaMetadataEncoderService
getEncoderWrapper(String) - Method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService: Get the encoder wrapper for a tenant.
getEncodingRules() - Method in class io.confluent.kafka.schemaregistry.storage.RuleSet
getErrorResponse(Response.Status, String) - Static method in class io.confluent.kafka.schemaregistry.rest.filters.ContextFilter
getExpr() - Method in class io.confluent.kafka.schemaregistry.storage.Rule
getField2() - Method in class otherns.Subrecord.Builder: Gets the value of the 'field2' field.
getField2() - Method in class otherns.Subrecord: Gets the value of the 'field2' field.
getGroupId() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
getGroupId() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getGuid() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
getGuid(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getGuid(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getHeader(String) - Method in class io.confluent.kafka.schemaregistry.rest.MutableRequest
getHeaderNames() - Method in class io.confluent.kafka.schemaregistry.rest.MutableRequest: Get the unique (case-insensitive) header names in customHeaders and HttpServletRequest.
getHeaders() - Method in class io.confluent.kafka.schemaregistry.rest.MutableRequest
getHeaders(String) - Method in class io.confluent.kafka.schemaregistry.rest.MutableRequest
getHost() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
getHostnameVerifier() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getHostnameVerifier() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getId() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
getId(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getId(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getIdentityGenerator() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
getIdsByGuid(String) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SchemasResource
getIdWithResponse(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getInterInstanceListener(List<NamedURI>, String, String) - Static method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry: This method returns a listener to be used for inter-instance communication.
getJsonMapper() - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication
getKafkaClusterId() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
getKafkaClusterId() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getKafkaStore() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
getKafkaStore() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getKeysetHandle() - Method in class io.confluent.kafka.schemaregistry.storage.encoder.KeysetWrapper
getKeyType() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKey
getKind() - Method in class io.confluent.kafka.schemaregistry.storage.Rule
getLatestSchemaMetadata(String) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getLatestVersion(String) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getLatestVersion(String) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getLatestWithMetadata(AsyncResponse, String, List<String>, List<String>, String, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SubjectsResource
getLatestWithMetadata(String, Map<String, String>, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getLatestWithMetadata(String, Map<String, String>, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getLeaderEligibility() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
getLeaderInitializationLatencyMetric() - Method in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
getLeaderNode() - Method in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
getLifecycle() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
getLookupCache() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getLookupCache() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getMagicByte() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKey
getMaxId(SchemaValue) - Method in interface io.confluent.kafka.schemaregistry.id.IdGenerator: Returns the current max id from the generator
getMaxId(SchemaValue) - Method in class io.confluent.kafka.schemaregistry.id.IncrementalIdGenerator
getMd5() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
getMd5Bytes() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
getMetadata() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
getMetadataEncoder() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getMetadataEncoder() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getMetrics() - Method in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
getMetricsContainer() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getMetricsContainer() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getMetricsContext() - Method in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
getMetricsTags() - Method in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
getMigrationRules() - Method in class io.confluent.kafka.schemaregistry.storage.RuleSet
getMode() - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getMode() - Method in class io.confluent.kafka.schemaregistry.storage.ModeValue
getMode() - Method in class io.confluent.kafka.schemaregistry.storage.Rule
getMode(String) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getMode(String) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getMode(String) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getMode(String, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.ModeResource
getModeInScope(String) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getModeInScope(String) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getName() - Method in class io.confluent.kafka.schemaregistry.storage.Rule
getName() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaReference
getNodeCountMetric() - Method in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
getOffset() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryValue
getOnFailure() - Method in class io.confluent.kafka.schemaregistry.storage.Rule
getOnSuccess() - Method in class io.confluent.kafka.schemaregistry.storage.Rule
getOrCreateEncoder(String) - Method in class io.confluent.kafka.schemaregistry.storage.encoder.KafkaMetadataEncoderService
getOrCreateEncoder(String) - Method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService
getOverriddenSslConfigs(NamedURI) - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
getOverrideMetadata() - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
getOverrideRuleSet() - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
getParams() - Method in class io.confluent.kafka.schemaregistry.storage.Rule
getPort() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
getPrimitive(String) - Static method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService
getProperties() - Method in class io.confluent.kafka.schemaregistry.storage.Metadata
getReferencedBy(SchemaKey, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getReferencedBy(String, VersionId, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getReferencedBy(String, VersionId, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getReferencedBy(String, String, boolean, int, int) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SubjectVersionsResource
getReferences() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
getRemoteAddr(Request) - Method in class io.confluent.kafka.schemaregistry.rest.RequestHeaderHandler
getRequestId(List<String>) - Method in class io.confluent.kafka.schemaregistry.rest.RequestHeaderHandler
getResource() - Method in exception io.confluent.kafka.schemaregistry.exceptions.AssociationForResourceExistsException
getResourceExtensions() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getResourceExtensions() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getResourceId() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
getResourceName() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationKey
getResourceName() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
getResourceNamespace() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationKey
getResourceNamespace() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
getResourceType() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationKey
getResourceType() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
getRuleSet() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
getRuleSetHandler() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getRuleSetHandler() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getSchema() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry.RawSchema
getSchema() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
getSchema() - Method in class otherns.Subrecord
getSchema(Integer, String, String, String, List<String>, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SchemasResource
getSchemaByGuid(String, String) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getSchemaByGuid(String, String) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SchemasResource
getSchemaById(int) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getSchemaBySubjectAndId(String, int) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getSchemaByVersion(String, String, String, String, boolean, List<String>) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SubjectVersionsResource
getSchemaId() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaIdAndSubjects
getSchemaMetadata(String, int) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getSchemaMetadata(String, int, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getSchemaOnly(Integer, String, String) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SchemasResource
getSchemaOnly(String, String, String, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SubjectVersionsResource
getSchemaRegistry() - Method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService
getSchemaRegistryDeployment() - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getSchemaRegistryDeployment() - Method in class io.confluent.kafka.schemaregistry.rest.resources.ServerMetadataResource
getSchemaRegistryDeployment(Map<String, Object>) - Static method in class io.confluent.kafka.schemaregistry.utils.Props
getSchemaRegistryServerVersion() - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getSchemaRegistryVersion() - Method in class io.confluent.kafka.schemaregistry.rest.resources.ServerMetadataResource
getSchemas(String, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getSchemas(String, boolean, boolean, boolean, String, String, List<String>, LifecyclePolicy, int, int) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SchemasResource
getSchemasCreated() - Method in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
getSchemasCreated(String) - Method in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
getSchemasDeleted() - Method in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
getSchemasDeleted(String) - Method in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
getSchemaType() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
getSchemaTypes() - Method in class io.confluent.kafka.schemaregistry.rest.resources.SchemasResource
getSchemaUpdateHandler(SchemaRegistryConfig) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
getSchemaValue(SchemaKey) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getSchemaValue(SchemaKey) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getScheme() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
getSensitive() - Method in class io.confluent.kafka.schemaregistry.storage.Metadata
getSerializer() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
getSpecificData() - Method in class otherns.Subrecord
getSslFactory() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getSslFactory() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getStaticLocations() - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
getStaticResources() - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication
getSubject() - Method in exception io.confluent.kafka.schemaregistry.exceptions.AssociationFrozenException
getSubject() - Method in exception io.confluent.kafka.schemaregistry.exceptions.SchemaVersionNotSoftDeletedException
getSubject() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaReference
getSubject() - Method in class io.confluent.kafka.schemaregistry.storage.SubjectKey
getSubject() - Method in class io.confluent.kafka.schemaregistry.storage.SubjectValue
getSubjectLevelConfig(String, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.ConfigResource
getSubjects(Integer, String, boolean, int, int) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SchemasResource
getTags() - Method in class io.confluent.kafka.schemaregistry.storage.Metadata
getTags() - Method in class io.confluent.kafka.schemaregistry.storage.Rule
getTenant() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationKey
getTenant() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
getTenant() - Method in class io.confluent.kafka.schemaregistry.storage.ContextKey
getTenant() - Method in class io.confluent.kafka.schemaregistry.storage.ContextValue
getTimestamp() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryValue
getTopLevelConfig(boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.ConfigResource
getTopLevelMode(boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.ModeResource
getType() - Method in class io.confluent.kafka.schemaregistry.storage.Rule
getUrl() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
getUsingContexts(String, int, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getUsingContexts(String, int, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
getVersion() - Method in exception io.confluent.kafka.schemaregistry.exceptions.SchemaVersionNotSoftDeletedException
getVersion() - Method in class io.confluent.kafka.schemaregistry.storage.DeleteSubjectValue
getVersion() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaKey
getVersion() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaReference
getVersion() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
getVersion() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
getVersion() - Static method in class io.confluent.kafka.schemaregistry.utils.AppInfoParser
getVersion(String) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaIdAndSubjects
getVersion(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getVersion(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
getVersionId() - Method in class io.confluent.kafka.schemaregistry.rest.VersionId
getVersions(Integer, String, boolean, int, int) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SchemasResource
getVersionsWithSubjectPrefix(String, boolean, LookupFilter, boolean, Predicate<Schema>) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
getVersionsWithSubjectPrefix(String, boolean, LookupFilter, boolean, Predicate<Schema>) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry

H

handle(ConfigUpdateRequest) - Method in class io.confluent.kafka.schemaregistry.rest.handlers.CompositeUpdateRequestHandler
handle(ConfigUpdateRequest) - Method in interface io.confluent.kafka.schemaregistry.rest.handlers.UpdateRequestHandler
handle(ConfigUpdateRequest, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.rest.handlers.CompositeUpdateRequestHandler
handle(ConfigUpdateRequest, Map<String, String>) - Method in interface io.confluent.kafka.schemaregistry.rest.handlers.UpdateRequestHandler
handle(Schema, TagSchemaRequest) - Method in class io.confluent.kafka.schemaregistry.rest.handlers.CompositeUpdateRequestHandler
handle(Schema, TagSchemaRequest) - Method in interface io.confluent.kafka.schemaregistry.rest.handlers.UpdateRequestHandler
handle(Schema, TagSchemaRequest) - Method in class io.confluent.kafka.schemaregistry.storage.RuleSetHandler
handle(Schema, TagSchemaRequest, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.rest.handlers.CompositeUpdateRequestHandler
handle(Schema, TagSchemaRequest, Map<String, String>) - Method in interface io.confluent.kafka.schemaregistry.rest.handlers.UpdateRequestHandler
handle(String, boolean, RegisterSchemaRequest) - Method in class io.confluent.kafka.schemaregistry.rest.handlers.CompositeUpdateRequestHandler
handle(String, boolean, RegisterSchemaRequest) - Method in interface io.confluent.kafka.schemaregistry.rest.handlers.UpdateRequestHandler
handle(String, boolean, RegisterSchemaRequest) - Method in class io.confluent.kafka.schemaregistry.storage.RuleSetHandler
handle(String, boolean, RegisterSchemaRequest, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.rest.handlers.CompositeUpdateRequestHandler
handle(String, boolean, RegisterSchemaRequest, Map<String, String>) - Method in interface io.confluent.kafka.schemaregistry.rest.handlers.UpdateRequestHandler
handle(String, ConfigUpdateRequest) - Method in class io.confluent.kafka.schemaregistry.rest.handlers.CompositeUpdateRequestHandler
handle(String, ConfigUpdateRequest) - Method in interface io.confluent.kafka.schemaregistry.rest.handlers.UpdateRequestHandler
handle(String, ConfigUpdateRequest) - Method in class io.confluent.kafka.schemaregistry.storage.RuleSetHandler
handle(String, ConfigUpdateRequest, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.rest.handlers.CompositeUpdateRequestHandler
handle(String, ConfigUpdateRequest, Map<String, String>) - Method in interface io.confluent.kafka.schemaregistry.rest.handlers.UpdateRequestHandler
handle(Request, Response, Callback) - Method in class io.confluent.kafka.schemaregistry.rest.JsonErrorHandler
handle(Request, Response, Callback) - Method in class io.confluent.kafka.schemaregistry.rest.RequestHeaderHandler
handleUpdate(SchemaRegistryKey, SchemaRegistryValue, SchemaRegistryValue, TopicPartition, long, long) - Method in class io.confluent.kafka.schemaregistry.storage.CompositeSchemaUpdateHandler: Invoked on every new schema written to the Kafka store
handleUpdate(SchemaRegistryKey, SchemaRegistryValue, SchemaRegistryValue, TopicPartition, long, long) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStoreMessageHandler: Invoked on every new schema written to the Kafka store
handleUpdate(K, V, V, TopicPartition, long, long) - Method in interface io.confluent.kafka.schemaregistry.storage.StoreUpdateHandler: Invoked on every new K,V pair written to the store
hasCustomCoders() - Method in class otherns.Subrecord
hasField2() - Method in class otherns.Subrecord.Builder: Checks whether the 'field2' field has been set.
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry.RawSchema
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationKey
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.ClearSubjectKey
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.ClearSubjectValue
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.ConfigKey
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.ContextKey
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.ContextValue
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.DeleteSubjectKey
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.DeleteSubjectValue
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.MD5
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.Metadata
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.ModeKey
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.ModeValue
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.NoopKey
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.Rule
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.RuleSet
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaIdAndSubjects
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaKey
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaReference
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKey
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.SubjectKey
hashCode() - Method in class io.confluent.kafka.schemaregistry.storage.SubjectValue
hashCode() - Method in class otherns.Subrecord
hasNext() - Method in class io.confluent.kafka.schemaregistry.storage.FilteredIterator
hasNext() - Method in class io.confluent.kafka.schemaregistry.storage.TransformedIterator
hasSubject(String) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaIdAndSubjects
hasSubjects(String, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
hasSubjects(String, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
hasSubjects(String, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Returns whether there exist schemas (that are not deleted) that match the given subject.
hasSubjects(String, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
healthy() - Method in interface io.confluent.kafka.schemaregistry.rest.extensions.SchemaRegistryResourceExtension
healthy() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
healthy() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
HOST_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
HOST_NAME_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: host.name
HOST_PORT_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
HOST_PORT_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
HTTP - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
HTTPS - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig

I

id(SchemaValue) - Method in interface io.confluent.kafka.schemaregistry.id.IdGenerator: Provides the id for the schema.
id(SchemaValue) - Method in class io.confluent.kafka.schemaregistry.id.IncrementalIdGenerator
ID_DOES_NOT_MATCH_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
idByGuid(String, String) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
idByGuid(String, String) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Provides the id for the provided guid and context.
idDoesNotMatchException(Throwable) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
IdDoesNotMatchException - Exception in io.confluent.kafka.schemaregistry.exceptions: Indicates a schema already exists with a different ID.
IdDoesNotMatchException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IdDoesNotMatchException
IdDoesNotMatchException(int, int) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IdDoesNotMatchException
IdDoesNotMatchException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IdDoesNotMatchException
IdDoesNotMatchException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IdDoesNotMatchException
IdDoesNotMatchException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IdDoesNotMatchException
identityGenerator(SchemaRegistryConfig) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
IdGenerationException - Exception in io.confluent.kafka.schemaregistry.exceptions
IdGenerationException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IdGenerationException
IdGenerationException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IdGenerationException
IdGenerationException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IdGenerationException
IdGenerationException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IdGenerationException
IdGenerator - Interface in io.confluent.kafka.schemaregistry.id: Internal interface used for generating id while registering schema.
IGNORE_FAILURE - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.StoreUpdateHandler.ValidationStatus
IMPORT - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.Mode
INCLUDE_DELETED - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.LookupFilter
INCOMPATIBLE_SCHEMA_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
incompatibleSchemaException(String, Throwable) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
IncompatibleSchemaException - Exception in io.confluent.kafka.schemaregistry.exceptions: Indicates the schema is incompatible with the registered schema
IncompatibleSchemaException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IncompatibleSchemaException
IncompatibleSchemaException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IncompatibleSchemaException
IncompatibleSchemaException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IncompatibleSchemaException
IncompatibleSchemaException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IncompatibleSchemaException
IncrementalIdGenerator - Class in io.confluent.kafka.schemaregistry.id
IncrementalIdGenerator(SchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.id.IncrementalIdGenerator
init() - Method in interface io.confluent.kafka.schemaregistry.id.IdGenerator: Initialize the underlying generator.
init() - Method in class io.confluent.kafka.schemaregistry.id.IncrementalIdGenerator
init() - Method in class io.confluent.kafka.schemaregistry.leaderelector.kafka.KafkaGroupLeaderElector
init() - Method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService: Initialize the metadata encoder service by rotating the secrets if needed.
init() - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
init() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
init() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore
init() - Method in interface io.confluent.kafka.schemaregistry.storage.LeaderElector
init() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
init() - Method in interface io.confluent.kafka.schemaregistry.storage.Store
init() - Method in class io.confluent.kafka.schemaregistry.tools.SchemaRegistryClientPerformance
init() - Method in class io.confluent.kafka.schemaregistry.tools.SchemaRegistryPerformance
init(Map<TopicPartition, Long>) - Method in class io.confluent.kafka.schemaregistry.storage.CompositeSchemaUpdateHandler: Invoked before the cache is initialized.
init(Map<TopicPartition, Long>) - Method in interface io.confluent.kafka.schemaregistry.storage.StoreUpdateHandler: Invoked before the cache is initialized.
INIT_RESOURCE_EXTENSION_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
INIT_RESOURCE_EXTENSION_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
initialized - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
initialized - Variable in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService
initialized() - Method in interface io.confluent.kafka.schemaregistry.rest.extensions.SchemaRegistryResourceExtension
initialized() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
initialized() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore
initialized() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
initiateShutdown() - Method in class io.confluent.kafka.schemaregistry.utils.ShutdownableThread
initLatch - Variable in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService
initProviders() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
initResourceExtensions() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
initSchemaRegistry(SchemaRegistryConfig) - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication
InMemoryCache<K,V> - Class in io.confluent.kafka.schemaregistry.storage: In-memory store based on maps
InMemoryCache(Serializer<K, V>) - Constructor for class io.confluent.kafka.schemaregistry.storage.InMemoryCache
INTER_INSTANCE_HEADERS_WHITELIST_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
INTER_INSTANCE_HEADERS_WHITELIST_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
INTER_INSTANCE_LISTENER_NAME_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
INTER_INSTANCE_LISTENER_NAME_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
INTER_INSTANCE_PROTOCOL_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
interInstanceListenerName() - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: Gets the inter.instance.listener.name setting.
interInstanceProtocol() - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: Gets the inter.instance.protocol setting, handling the deprecated schema.registry.inter.instance.protocol setting.
INVALID_ASSOCIATION_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
INVALID_ASSOCIATION_MESSAGE_FORMAT - Static variable in exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidAssociationException
INVALID_COMPATIBILITY_LEVEL_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
INVALID_CONTEXT_MESSAGE_FORMAT - Static variable in exception io.confluent.kafka.schemaregistry.rest.exceptions.RestContextNotEmptyException
INVALID_MODE_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
INVALID_RULESET_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
INVALID_SCHEMA_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
INVALID_SUBJECT_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
INVALID_SUBJECT_MESSAGE_FORMAT - Static variable in exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidSubjectException
INVALID_VERSION_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
INVALID_VERSION_MESSAGE_FORMAT - Static variable in exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidVersionException
invalidAssociationException(String, String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
invalidateFromNewSchemaCache(Schema) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
invalidateFromNewSchemaCache(Schema) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
invalidateFromOldSchemaCache(Schema) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
invalidSchemaException(Throwable) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
InvalidSchemaException - Exception in io.confluent.kafka.schemaregistry.exceptions: Indicates an invalid schema that does not conform to the expected format of the schema
InvalidSchemaException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.InvalidSchemaException
InvalidSchemaException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.InvalidSchemaException
InvalidSchemaException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.InvalidSchemaException
InvalidSchemaException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.InvalidSchemaException
invalidSubjectException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
invalidVersionException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
InvalidVersionException - Exception in io.confluent.kafka.schemaregistry.exceptions: Indicates that the version is not a valid version id.
InvalidVersionException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.InvalidVersionException
InvalidVersionException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.InvalidVersionException
InvalidVersionException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.InvalidVersionException
InvalidVersionException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.InvalidVersionException
io.confluent.kafka.schemaregistry.avro - package io.confluent.kafka.schemaregistry.avro
io.confluent.kafka.schemaregistry.exceptions - package io.confluent.kafka.schemaregistry.exceptions
io.confluent.kafka.schemaregistry.id - package io.confluent.kafka.schemaregistry.id
io.confluent.kafka.schemaregistry.leaderelector.kafka - package io.confluent.kafka.schemaregistry.leaderelector.kafka
io.confluent.kafka.schemaregistry.metrics - package io.confluent.kafka.schemaregistry.metrics
io.confluent.kafka.schemaregistry.rest - package io.confluent.kafka.schemaregistry.rest
io.confluent.kafka.schemaregistry.rest.client - package io.confluent.kafka.schemaregistry.rest.client
io.confluent.kafka.schemaregistry.rest.exceptions - package io.confluent.kafka.schemaregistry.rest.exceptions
io.confluent.kafka.schemaregistry.rest.extensions - package io.confluent.kafka.schemaregistry.rest.extensions
io.confluent.kafka.schemaregistry.rest.filters - package io.confluent.kafka.schemaregistry.rest.filters
io.confluent.kafka.schemaregistry.rest.handlers - package io.confluent.kafka.schemaregistry.rest.handlers
io.confluent.kafka.schemaregistry.rest.resources - package io.confluent.kafka.schemaregistry.rest.resources
io.confluent.kafka.schemaregistry.storage - package io.confluent.kafka.schemaregistry.storage
io.confluent.kafka.schemaregistry.storage.encoder - package io.confluent.kafka.schemaregistry.storage.encoder
io.confluent.kafka.schemaregistry.storage.exceptions - package io.confluent.kafka.schemaregistry.storage.exceptions
io.confluent.kafka.schemaregistry.storage.serialization - package io.confluent.kafka.schemaregistry.storage.serialization
io.confluent.kafka.schemaregistry.tools - package io.confluent.kafka.schemaregistry.tools
io.confluent.kafka.schemaregistry.utils - package io.confluent.kafka.schemaregistry.utils
isCompatible(String, Schema, List<SchemaKey>, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
isCompatible(String, Schema, List<SchemaKey>, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
isCompatibleWithPrevious(Config, ParsedSchema, List<ParsedSchemaHolder>) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
isDeleted() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
isDisabled() - Method in class io.confluent.kafka.schemaregistry.storage.Rule
isEmpty() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaIdAndSubjects
isFrozen() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
isLatest() - Method in class io.confluent.kafka.schemaregistry.rest.VersionId
isLeader() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
isLeader() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
isLeader() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
isNew() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry.RawSchema
isNormalize() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry.RawSchema
isNormalize() - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
isPersistent() - Method in interface io.confluent.kafka.schemaregistry.storage.Store: Whether the store is persistent.
isReadOnlyMode(String) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
isRotationNeeded() - Method in class io.confluent.kafka.schemaregistry.storage.encoder.KeysetWrapper
isRunning() - Method in class io.confluent.kafka.schemaregistry.utils.ShutdownableThread
isSchemaFieldValidationEnabled(Config) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
isSchemaNewSchemaValidationEnabled(Config) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
isShutdownComplete() - Method in class io.confluent.kafka.schemaregistry.utils.ShutdownableThread
isShutdownInitiated() - Method in class io.confluent.kafka.schemaregistry.utils.ShutdownableThread
isSubjectVersionDeleted(String, int) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
isThreadFailed() - Method in class io.confluent.kafka.schemaregistry.utils.ShutdownableThread
isValidateFields() - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
isValidateNewSchemas() - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
isValidateRules() - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue

J

JettyEofExceptionMapper - Class in io.confluent.kafka.schemaregistry.rest.exceptions: This class is intended to catch Early EOF errors that occur when the client disconnects while the server is reading from the input stream.
JettyEofExceptionMapper() - Constructor for class io.confluent.kafka.schemaregistry.rest.exceptions.JettyEofExceptionMapper
JettyEofExceptionWriterInterceptor - Class in io.confluent.kafka.schemaregistry.rest.exceptions: A WriterInterceptor to swallow EofException which occurs when a client disconnects before the complete response could be sent.
JettyEofExceptionWriterInterceptor() - Constructor for class io.confluent.kafka.schemaregistry.rest.exceptions.JettyEofExceptionWriterInterceptor
JMX_PREFIX - Static variable in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
JsonErrorHandler - Class in io.confluent.kafka.schemaregistry.rest
JsonErrorHandler() - Constructor for class io.confluent.kafka.schemaregistry.rest.JsonErrorHandler

K

KAFAKSTORE_SSL_ENABLED_PROTOCOLS_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFAKSTORE_SSL_KEYSTORE_TYPE_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFAKSTORE_SSL_PROTOCOL_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFAKSTORE_SSL_PROVIDER_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFAKSTORE_SSL_TRUSTSTORE_TYPE_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKAGROUP_HEARTBEAT_INTERVAL_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKAGROUP_HEARTBEAT_INTERVAL_MS_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: kafkagroup.heartbeat.interval.ms
KAFKAGROUP_REBALANCE_TIMEOUT_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKAGROUP_REBALANCE_TIMEOUT_MS_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: kafkagroup.rebalance.timeout.ms
KAFKAGROUP_SESSION_TIMEOUT_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKAGROUP_SESSION_TIMEOUT_MS_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: kafkagroup.session.timeout.ms
KafkaGroupLeaderElector - Class in io.confluent.kafka.schemaregistry.leaderelector.kafka
KafkaGroupLeaderElector(SchemaRegistryConfig, SchemaRegistryIdentity, SchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.leaderelector.kafka.KafkaGroupLeaderElector
KafkaMetadataEncoderService - Class in io.confluent.kafka.schemaregistry.storage.encoder
KafkaMetadataEncoderService(SchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.storage.encoder.KafkaMetadataEncoderService
KafkaMetadataEncoderService(SchemaRegistry, Cache<String, KeysetWrapper>) - Constructor for class io.confluent.kafka.schemaregistry.storage.encoder.KafkaMetadataEncoderService
KafkaSchemaRegistry - Class in io.confluent.kafka.schemaregistry.storage
KafkaSchemaRegistry(SchemaRegistryConfig, Serializer<SchemaRegistryKey, SchemaRegistryValue>) - Constructor for class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
kafkaStore(SchemaRegistryConfig) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
KafkaStore<K,V> - Class in io.confluent.kafka.schemaregistry.storage
KafkaStore(SchemaRegistryConfig, StoreUpdateHandler<K, V>, Serializer<K, V>, Store<K, V>, K) - Constructor for class io.confluent.kafka.schemaregistry.storage.KafkaStore
KAFKASTORE_BOOTSTRAP_SERVERS_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_BOOTSTRAP_SERVERS_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_CHECKPOINT_DIR_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: kafkastore.checkpoint.dir
KAFKASTORE_CHECKPOINT_DIR_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_CHECKPOINT_VERSION_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: kafkastore.checkpoint.version
KAFKASTORE_CHECKPOINT_VERSION_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_CONNECTION_URL_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: Deprecated.
KAFKASTORE_CONNECTION_URL_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_GROUP_ID_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_GROUP_ID_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_INIT_TIMEOUT_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: kafkastore.init.timeout.ms
KAFKASTORE_INIT_TIMEOUT_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_INIT_WAIT_FOR_READER_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: kafkastore.init.wait.for.reader
KAFKASTORE_INIT_WAIT_FOR_READER_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SASL_KERBEROS_KINIT_CMD_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SASL_KERBEROS_KINIT_CMD_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SASL_KERBEROS_MIN_TIME_BEFORE_RELOGIN_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SASL_KERBEROS_MIN_TIME_BEFORE_RELOGIN_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SASL_KERBEROS_SERVICE_NAME_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SASL_KERBEROS_SERVICE_NAME_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SASL_KERBEROS_TICKET_RENEW_JITTER_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SASL_KERBEROS_TICKET_RENEW_JITTER_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SASL_KERBEROS_TICKET_RENEW_WINDOW_FACTOR_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SASL_KERBEROS_TICKET_RENEW_WINDOW_FACTOR_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SASL_MECHANISM_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SASL_MECHANISM_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SECURITY_PROTOCOL_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SECURITY_PROTOCOL_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SECURITY_PROTOCOL_PLAINTEXT - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: Deprecated.
KAFKASTORE_SECURITY_PROTOCOL_SSL - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: Deprecated.
KAFKASTORE_SSL_CIPHER_SUITES_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_CIPHER_SUITES_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_ENABLED_PROTOCOLS_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_KEY_PASSWORD_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_KEY_PASSWORD_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_KEYMANAGER_ALGORITHM_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_KEYMANAGER_ALGORITHM_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_KEYSTORE_LOCATION_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_KEYSTORE_LOCATION_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_KEYSTORE_PASSWORD_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_KEYSTORE_PASSWORD_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_KEYSTORE_TYPE_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_PROTOCOL_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_PROVIDER_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_TRUSTMANAGER_ALGORITHM_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_TRUSTMANAGER_ALGORITHM_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_TRUSTSTORE_LOCATION_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_TRUSTSTORE_LOCATION_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_TRUSTSTORE_PASSWORD_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_TRUSTSTORE_PASSWORD_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_SSL_TRUSTSTORE_TYPE_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_TIMEOUT_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: kafkastore.timeout.ms
KAFKASTORE_TIMEOUT_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_TOPIC_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: kafkastore.topic
KAFKASTORE_TOPIC_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_TOPIC_REPLICATION_FACTOR_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: kafkastore.topic.replication.factor
KAFKASTORE_TOPIC_REPLICATION_FACTOR_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_TOPIC_SKIP_VALIDATION_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: kafkastore.topic.skip.validation
KAFKASTORE_TOPIC_SKIP_VALIDATION_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_UPDATE_HANDLERS_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: kafkastore.update.handler
KAFKASTORE_UPDATE_HANDLERS_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KAFKASTORE_WRITE_MAX_RETRIES_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: kafkastore.write.max.retries
KAFKASTORE_WRITE_RETRIES_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
KafkaStoreMessageHandler - Class in io.confluent.kafka.schemaregistry.storage
KafkaStoreMessageHandler(SchemaRegistry, LookupCache<SchemaRegistryKey, SchemaRegistryValue>, IdGenerator) - Constructor for class io.confluent.kafka.schemaregistry.storage.KafkaStoreMessageHandler
KafkaStoreReaderThread<K,V> - Class in io.confluent.kafka.schemaregistry.storage: Thread that reads schema registry state from the Kafka compacted topic and modifies the local store to be consistent.
KafkaStoreReaderThread(String, String, String, StoreUpdateHandler<K, V>, Serializer<K, V>, Store<K, V>, Producer<byte[], byte[]>, K, AtomicBoolean, SchemaRegistryConfig) - Constructor for class io.confluent.kafka.schemaregistry.storage.KafkaStoreReaderThread
KeysetWrapper - Class in io.confluent.kafka.schemaregistry.storage.encoder
KeysetWrapper(KeysetHandle, boolean) - Constructor for class io.confluent.kafka.schemaregistry.storage.encoder.KeysetWrapper
KeysetWrapperDeserializer - Class in io.confluent.kafka.schemaregistry.storage.encoder
KeysetWrapperDeserializer(SchemaRegistryConfig) - Constructor for class io.confluent.kafka.schemaregistry.storage.encoder.KeysetWrapperDeserializer
KeysetWrapperSerde - Class in io.confluent.kafka.schemaregistry.storage.encoder
KeysetWrapperSerde(SchemaRegistryConfig) - Constructor for class io.confluent.kafka.schemaregistry.storage.encoder.KeysetWrapperSerde
KeysetWrapperSerializer - Class in io.confluent.kafka.schemaregistry.storage.encoder
KeysetWrapperSerializer(SchemaRegistryConfig) - Constructor for class io.confluent.kafka.schemaregistry.storage.encoder.KeysetWrapperSerializer
keyTemplate - Variable in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService
keyType - Variable in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKey
keyType - Variable in enum class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKeyType

L

lastOffset(String) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore
LazyParsedSchemaHolder - Class in io.confluent.kafka.schemaregistry.storage
LazyParsedSchemaHolder(SchemaRegistry, SchemaKey) - Constructor for class io.confluent.kafka.schemaregistry.storage.LazyParsedSchemaHolder
LEADER_CONNECT_TIMEOUT_MS - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: leader.connect.timeout.ms*
LEADER_CONNECT_TIMEOUT_MS_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
LEADER_ELECTION_DELAY - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: leader.election.delay*
LEADER_ELECTION_DELAY_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
LEADER_ELECTION_STICKY - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: leader.election.sticky*
LEADER_ELECTION_STICKY_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
LEADER_ELIGIBILITY - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
LEADER_ELIGIBILITY_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
LEADER_READ_TIMEOUT_MS - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: leader.read.timeout.ms*
LEADER_READ_TIMEOUT_MS_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
LeaderAwareSchemaRegistry - Interface in io.confluent.kafka.schemaregistry.storage: Internal interface for schema registry implementations.
LeaderElector - Interface in io.confluent.kafka.schemaregistry.storage
leaderIdentity() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry: Return the identity of the SchemaRegistry that this instance thinks is current leader.
leaderIdentity() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
leaderLock() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore
leaderRestService() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
leaderRestService() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
Lifecycle - Enum Class in io.confluent.kafka.schemaregistry.storage
list(String, int, int, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SubjectsResource
listContexts() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
listContexts() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
listContexts(int, int, String) - Method in class io.confluent.kafka.schemaregistry.rest.resources.ContextsResource
LISTENER_NAME_PREFIX - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
listIdsForGuid(String) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
listIdsForGuid(String) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
listSubjects() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
listSubjects(LookupFilter) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
listSubjects(LookupFilter) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
listSubjectsForId(int, String) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
listSubjectsForId(int, String) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
listSubjectsForId(int, String, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
listSubjectsForId(int, String, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
listSubjectsWithPrefix(String, LookupFilter) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
listSubjectsWithPrefix(String, LookupFilter) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
listVersions(String, boolean, boolean, int, int) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SubjectVersionsResource
listVersionsForId(int, String) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
listVersionsForId(int, String, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
listVersionsForId(int, String, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
loadSchema(Schema, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry: Loads a schema from the cache or parses it if not cached.
LocalSchemaRegistryClient - Class in io.confluent.kafka.schemaregistry.rest.client: Local implementation of SchemaRegistryClient that can be used without going through HTTP.
LocalSchemaRegistryClient(SchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
LocalSchemaRegistryClient(SchemaRegistry, List<SchemaProvider>) - Constructor for class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
LOCK_FILE_NAME - Static variable in class io.confluent.kafka.schemaregistry.storage.OffsetCheckpoint
lockFor(String) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore
logPrefix - Variable in class io.confluent.kafka.schemaregistry.utils.ShutdownableThread
logSchemaOp(Schema, String) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
lookupCache - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
lookupCache() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
LookupCache<K,V> - Interface in io.confluent.kafka.schemaregistry.storage: Internal interface that provides various indexed methods that help lookup the underlying schemas.
LookupFilter - Enum Class in io.confluent.kafka.schemaregistry.storage
lookUpSchemaUnderSubject(Config, String, Schema, boolean, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
lookUpSchemaUnderSubject(AsyncResponse, String, boolean, String, boolean, RegisterSchemaRequest) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SubjectsResource
lookUpSchemaUnderSubject(String, Schema, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
lookUpSchemaUnderSubject(String, Schema, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry: Checks if given schema was ever registered under a subject.
lookUpSchemaUnderSubject(String, Schema, boolean, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
lookUpSchemaUnderSubjectUsingContexts(String, Schema, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
lookUpSchemaUnderSubjectUsingContexts(String, Schema, boolean, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry

M

magicByte - Variable in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKey
main(String[]) - Static method in class io.confluent.kafka.schemaregistry.rest.Main: Deprecated.

Starts an embedded Jetty server running the REST server.
main(String[]) - Static method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
main(String[]) - Static method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain: Starts an embedded Jetty server running the REST server.
main(String[]) - Static method in class io.confluent.kafka.schemaregistry.tools.SchemaRegistryClientPerformance
main(String[]) - Static method in class io.confluent.kafka.schemaregistry.tools.SchemaRegistryPerformance
Main - Class in io.confluent.kafka.schemaregistry.rest: Deprecated.
This is replaced by SchemaRegistryMain Keep this class in place for compatibility. See https://github.com/confluentinc/schema-registry/issues/194
Main() - Constructor for class io.confluent.kafka.schemaregistry.rest.Main: Deprecated.
makeParsedSchema(String, long) - Static method in class io.confluent.kafka.schemaregistry.tools.SchemaRegistryPerformance
makeSchema(String, long) - Static method in class io.confluent.kafka.schemaregistry.tools.SchemaRegistryPerformance
markLastWrittenOffsetInvalid() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore
MASTER_ELIGIBILITY - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: Deprecated.
matchingSubjectPredicate(String) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
MAX_VERSION - Static variable in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
maybePopulateFromPrevious(Config, Schema, List<ParsedSchemaHolder>, int, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
maybeRotateSecrets() - Method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService
maybeSetMetadataRuleSet(Config, Schema, Schema, Integer) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
MD5 - Class in io.confluent.kafka.schemaregistry.storage: Simple wrapper for 16 byte MD5 hash.
MD5(byte[]) - Constructor for class io.confluent.kafka.schemaregistry.storage.MD5
Metadata - Class in io.confluent.kafka.schemaregistry.storage: Metadata, which includes path annotations, arbitrary key-value properties, and a set of sensitive properties.
Metadata(Metadata) - Constructor for class io.confluent.kafka.schemaregistry.storage.Metadata
Metadata(SortedMap<String, SortedSet<String>>, SortedMap<String, String>, SortedSet<String>) - Constructor for class io.confluent.kafka.schemaregistry.storage.Metadata
METADATA_ENCODER_OLD_SECRET_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
METADATA_ENCODER_OLD_SECRET_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
METADATA_ENCODER_SECRET_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
METADATA_ENCODER_SECRET_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
METADATA_ENCODER_TOPIC_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
METADATA_ENCODER_TOPIC_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
METADATA_ENCODER_TOPIC_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
metadataEncoder - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
MetadataEncoderService - Class in io.confluent.kafka.schemaregistry.storage.encoder
MetadataEncoderService(SchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService
METRIC_CERTIFICATE_EXPIRATION - Static variable in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
METRIC_LEADER_INITIALIZATION_LATENCY - Static variable in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
METRIC_NAME_API_FAILURE_COUNT - Static variable in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
METRIC_NAME_API_SUCCESS_COUNT - Static variable in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
METRIC_NAME_AVRO_SCHEMAS_CREATED - Static variable in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
METRIC_NAME_AVRO_SCHEMAS_DELETED - Static variable in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
METRIC_NAME_CUSTOM_SCHEMA_PROVIDER - Static variable in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
METRIC_NAME_DELETED_COUNT - Static variable in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
METRIC_NAME_JSON_SCHEMAS_CREATED - Static variable in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
METRIC_NAME_JSON_SCHEMAS_DELETED - Static variable in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
METRIC_NAME_MASTER_SLAVE_ROLE - Static variable in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
METRIC_NAME_NODE_COUNT - Static variable in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
METRIC_NAME_PB_SCHEMAS_CREATED - Static variable in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
METRIC_NAME_PB_SCHEMAS_DELETED - Static variable in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
METRIC_NAME_REGISTERED_COUNT - Static variable in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
metricsContainer - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
MetricsContainer - Class in io.confluent.kafka.schemaregistry.metrics
MetricsContainer(SchemaRegistryConfig, String) - Constructor for class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
MIN_VERSION - Static variable in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry: Schema versions under a particular subject are indexed from MIN_VERSION.
mode(String, boolean, Mode) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
mode(String, boolean, Mode) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Retrieves the mode for a subject.
Mode - Enum Class in io.confluent.kafka.schemaregistry.storage
MODE - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKeyType
MODE_MUTABILITY - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: mode.mutability*
MODE_MUTABILITY_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
ModeKey - Class in io.confluent.kafka.schemaregistry.storage
ModeKey(String) - Constructor for class io.confluent.kafka.schemaregistry.storage.ModeKey
ModeResource - Class in io.confluent.kafka.schemaregistry.rest.resources
ModeResource(SchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.rest.resources.ModeResource
ModeValue - Class in io.confluent.kafka.schemaregistry.storage
ModeValue() - Constructor for class io.confluent.kafka.schemaregistry.storage.ModeValue
ModeValue(String, Mode) - Constructor for class io.confluent.kafka.schemaregistry.storage.ModeValue
modifySchemaTags(String, Schema, TagSchemaRequest) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
modifySchemaTagsOrForward(String, Schema, TagSchemaRequest, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
modifySchemaTagsOrForward(String, Schema, TagSchemaRequest, Map<String, String>) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
modifyTags(AsyncResponse, HttpHeaders, String, String, TagSchemaRequest) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SubjectVersionsResource
MutableRequest - Class in io.confluent.kafka.schemaregistry.rest: Allows for adding and replacing custom headers in the HttpServletRequest object.
MutableRequest(Request) - Constructor for class io.confluent.kafka.schemaregistry.rest.MutableRequest
mutateAssociations(AsyncResponse, HttpHeaders, String, boolean, AssociationBatchRequest) - Method in class io.confluent.kafka.schemaregistry.rest.resources.AssociationsResource
mutateAssociations(String, boolean, AssociationBatchRequest) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
mutateAssociations(String, boolean, AssociationBatchRequest) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
mutateAssociationsOrForward(String, boolean, AssociationBatchRequest, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
mutateAssociationsOrForward(String, boolean, AssociationBatchRequest, Map<String, String>) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
myIdentity() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry: Return json data encoding basic information about this SchemaRegistry instance, such as host, port, etc.
myIdentity() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry

N

newBuilder() - Static method in class otherns.Subrecord: Creates a new Subrecord RecordBuilder.
newBuilder(Subrecord) - Static method in class otherns.Subrecord: Creates a new Subrecord RecordBuilder by copying an existing Subrecord instance.
newBuilder(Subrecord.Builder) - Static method in class otherns.Subrecord: Creates a new Subrecord RecordBuilder by copying an existing Builder.
newSchemaCache - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
next() - Method in class io.confluent.kafka.schemaregistry.storage.FilteredIterator
next() - Method in class io.confluent.kafka.schemaregistry.storage.TransformedIterator
NO_ACTIVE_SUBJECT_VERSION_EXISTS_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
NO_ACTIVE_SUBJECT_VERSION_EXISTS_MESSAGE_FORMAT - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
noActiveSubjectVersionExistsException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
NoActiveSubjectVersionExistsException - Exception in io.confluent.kafka.schemaregistry.exceptions
NoActiveSubjectVersionExistsException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.NoActiveSubjectVersionExistsException
NoActiveSubjectVersionExistsException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.NoActiveSubjectVersionExistsException
NoActiveSubjectVersionExistsException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.NoActiveSubjectVersionExistsException
NoActiveSubjectVersionExistsException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.NoActiveSubjectVersionExistsException
NONE - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.ExecutionEnvironment
NOOP - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKeyType
NoopKey - Class in io.confluent.kafka.schemaregistry.storage
NoopKey() - Constructor for class io.confluent.kafka.schemaregistry.storage.NoopKey
normalizeContextLimit(int) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
normalizeContextLimit(int) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
normalizeLimit(int, int, int) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
normalizeSchemaLimit(int) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
normalizeSchemaLimit(int) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
normalizeSubjectLimit(int) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
normalizeSubjectLimit(int) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
normalizeSubjectVersionLimit(int) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
normalizeSubjectVersionLimit(int) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry

O

offset - Variable in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryValue
OffsetCheckpoint - Class in io.confluent.kafka.schemaregistry.storage: This class saves out a map of topic/partition=>offsets to a file.
OffsetCheckpoint(String, int, String) - Constructor for class io.confluent.kafka.schemaregistry.storage.OffsetCheckpoint
OffsetCheckpointReadOnly - Class in io.confluent.kafka.schemaregistry.storage: This class read a map of topic/partition=>offsets from a file.
OffsetCheckpointReadOnly(String, int, String) - Constructor for class io.confluent.kafka.schemaregistry.storage.OffsetCheckpointReadOnly
ofSchema(Schema) - Static method in class io.confluent.kafka.schemaregistry.storage.MD5
ofSchema(SchemaValue) - Static method in class io.confluent.kafka.schemaregistry.storage.MD5
ofSchema(String, List<SchemaReference>, Metadata, RuleSet) - Static method in class io.confluent.kafka.schemaregistry.storage.MD5
oldSchemaCache - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
onAssigned(SchemaRegistryProtocol.Assignment, int) - Method in class io.confluent.kafka.schemaregistry.leaderelector.kafka.KafkaGroupLeaderElector
onKeystoreCreated(KeyStore) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
onRevoked() - Method in class io.confluent.kafka.schemaregistry.leaderelector.kafka.KafkaGroupLeaderElector: This is a no-op during leader election if stickyLeaderElection is enabled as we're not revoking previous leader assignment.
onShutdown() - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication
onTruststoreCreated(KeyStore) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
OPERATION_NOT_PERMITTED_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
OPERATION_TIMEOUT_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
operationNotPermittedException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
OperationNotPermittedException - Exception in io.confluent.kafka.schemaregistry.exceptions: The requested operation is not permitted.
OperationNotPermittedException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.OperationNotPermittedException
OperationNotPermittedException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.OperationNotPermittedException
OperationNotPermittedException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.OperationNotPermittedException
OperationNotPermittedException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.OperationNotPermittedException
operationTimeoutException(String, Throwable) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
originalProperties() - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
otherns - package otherns

P

parseSchema(Schema) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
parseSchema(Schema) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
parseSchema(Schema) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
parseSchema(Schema, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
parseSchema(Schema, boolean, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
parseSchema(String) - Static method in class io.confluent.kafka.schemaregistry.avro.AvroUtils: Convert a schema string into a schema object and a canonical schema string.
parseSchema(String, String, List<SchemaReference>) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
pause(long, TimeUnit) - Method in class io.confluent.kafka.schemaregistry.utils.ShutdownableThread: Causes the current thread to wait until the shutdown is initiated, or the specified waiting time elapses.
port - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry.SchemeAndPort
post(Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.rest.resources.RootResource
postInit() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
postInit() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
postServerStart() - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication
properties() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
properties() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
PROPERTY_SCHEMA_REGISTRY_DEPLOYMENT_ATTRIBUTES - Static variable in class io.confluent.kafka.schemaregistry.utils.Props
props - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
Props - Class in io.confluent.kafka.schemaregistry.utils
Props() - Constructor for class io.confluent.kafka.schemaregistry.utils.Props
providers - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
put(int, Object) - Method in class otherns.Subrecord
put(K, V) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
put(K, V) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore
put(K, V) - Method in interface io.confluent.kafka.schemaregistry.storage.Store
putAll(Map<K, V>) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
putAll(Map<K, V>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore
putAll(Map<K, V>) - Method in interface io.confluent.kafka.schemaregistry.storage.Store
putEncoderWrapper(String, KeysetWrapper) - Method in class io.confluent.kafka.schemaregistry.storage.encoder.KafkaMetadataEncoderService
putEncoderWrapper(String, KeysetWrapper) - Method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService: Store an encoder wrapper for a tenant.
putHeader(String, String) - Method in class io.confluent.kafka.schemaregistry.rest.MutableRequest: Puts a new header will take precedence over existing header in the HttpServletRequest object.

R

RawSchema(Schema, boolean, boolean) - Constructor for class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry.RawSchema
read() - Method in class io.confluent.kafka.schemaregistry.storage.OffsetCheckpoint: Reads the offsets from the local checkpoint file, skipping any negative offsets it finds.
READ - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.RuleMode
readExternal(ObjectInput) - Method in class otherns.Subrecord
READONLY - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.Mode
READONLY_OVERRIDE - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.Mode: Deprecated.
Use Mode.READONLY with the global context (":.__GLOBAL:") instead.
READWRITE - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.Mode
record() - Method in class io.confluent.kafka.schemaregistry.metrics.SchemaRegistryMetric
record(double) - Method in class io.confluent.kafka.schemaregistry.metrics.SchemaRegistryMetric
REFERENCE_EXISTS_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
REFERENCE_EXISTS_MESSAGE_FORMAT - Static variable in exception io.confluent.kafka.schemaregistry.rest.exceptions.RestReferenceExistsException
referenceExistsException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
ReferenceExistsException - Exception in io.confluent.kafka.schemaregistry.exceptions: Indicates the schema cannot be deleted because another schema references it.
ReferenceExistsException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.ReferenceExistsException
ReferenceExistsException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.ReferenceExistsException
ReferenceExistsException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.ReferenceExistsException
ReferenceExistsException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.ReferenceExistsException
referencesSchema(SchemaKey) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
referencesSchema(SchemaKey) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Returns schemas that reference the given schema.
register(AsyncResponse, HttpHeaders, String, boolean, String, RegisterSchemaRequest) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SubjectVersionsResource
register(Configurable<?>, SchemaRegistryConfig, SchemaRegistry) - Method in interface io.confluent.kafka.schemaregistry.rest.extensions.SchemaRegistryResourceExtension
register(String, RegisterSchemaRequest, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
register(String, Schema) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
register(String, Schema, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
register(String, Schema, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry: Register the given schema under the given subject.
register(String, Schema, boolean, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
register(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
register(String, ParsedSchema, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
register(String, ParsedSchema, int, int) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
registerInitResourceExtensions(Configurable<?>, SchemaRegistryConfig) - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication
registerOrForward(String, RegisterSchemaRequest, boolean, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
registerOrForward(String, RegisterSchemaRequest, boolean, Map<String, String>) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
registerProviders(Map<String, SchemaProvider>, List<SchemaProvider>) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
registerWithResponse(String, ParsedSchema, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
remove() - Method in class io.confluent.kafka.schemaregistry.storage.FilteredIterator
remove() - Method in class io.confluent.kafka.schemaregistry.storage.TransformedIterator
removeCustomHandler(Handler.Singleton) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
removeIf(Predicate<SchemaKey>) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaIdAndSubjects
REQUEST_FORWARDING_FAILED_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
requestForwardingFailedException(String, Throwable) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
RequestHeaderBuilder - Class in io.confluent.kafka.schemaregistry.rest.resources
RequestHeaderBuilder() - Constructor for class io.confluent.kafka.schemaregistry.rest.resources.RequestHeaderBuilder
RequestHeaderHandler - Class in io.confluent.kafka.schemaregistry.rest
RequestHeaderHandler() - Constructor for class io.confluent.kafka.schemaregistry.rest.RequestHeaderHandler
RESERVED_FIELD_REMOVED - Static variable in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
reset() - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
RESOURCE_CERT_LABEL_NAME - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
RESOURCE_CERT_LABEL_TYPE - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
RESOURCE_EXTENSION_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
RESOURCE_LABEL_CLUSTER_ID - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
RESOURCE_LABEL_COMMIT_ID - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
RESOURCE_LABEL_GROUP_ID - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
RESOURCE_LABEL_KAFKA_CLUSTER_ID - Static variable in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
RESOURCE_LABEL_PREFIX - Static variable in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer
RESOURCE_LABEL_PREFIX - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
RESOURCE_LABEL_TYPE - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
RESOURCE_LABEL_VERSION - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
RESOURCE_STATIC_LOCATIONS_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
RESOURCE_STATIC_LOCATIONS_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
RESOURCE_WILDCARD - Static variable in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
resourceExtensions - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
RestCallMetricFilter - Class in io.confluent.kafka.schemaregistry.rest.filters
RestCallMetricFilter(SchemaRegistryMetric, SchemaRegistryMetric) - Constructor for class io.confluent.kafka.schemaregistry.rest.filters.RestCallMetricFilter
RestConflictException - Exception in io.confluent.kafka.schemaregistry.rest.exceptions
RestConflictException(String, int) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestConflictException
RestConflictException(String, int, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestConflictException
RestContextNotEmptyException - Exception in io.confluent.kafka.schemaregistry.rest.exceptions: Indicates that the context is not empty when it is expected to be.
RestContextNotEmptyException(String) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestContextNotEmptyException
RestIdDoesNotMatchException - Exception in io.confluent.kafka.schemaregistry.rest.exceptions: Indicates that the ID of an imported schema does not match the existing ID.
RestIdDoesNotMatchException() - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestIdDoesNotMatchException
RestIdDoesNotMatchException(String) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestIdDoesNotMatchException
RestIncompatibleSchemaException - Exception in io.confluent.kafka.schemaregistry.rest.exceptions: An exception thrown when the registered schema is not compatible with the latest schema according to the compatibility level.
RestIncompatibleSchemaException(String, int) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestIncompatibleSchemaException
RestIncompatibleSchemaException(String, int, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestIncompatibleSchemaException
RestInvalidAssociationException - Exception in io.confluent.kafka.schemaregistry.rest.exceptions: Indicates an invalid association property value
RestInvalidAssociationException(String, String) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidAssociationException
RestInvalidCompatibilityException - Exception in io.confluent.kafka.schemaregistry.rest.exceptions
RestInvalidCompatibilityException() - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidCompatibilityException
RestInvalidCompatibilityException(String) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidCompatibilityException
RestInvalidModeException - Exception in io.confluent.kafka.schemaregistry.rest.exceptions
RestInvalidModeException() - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidModeException
RestInvalidModeException(String) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidModeException
RestInvalidRuleSetException - Exception in io.confluent.kafka.schemaregistry.rest.exceptions
RestInvalidRuleSetException(String) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidRuleSetException
RestInvalidSchemaException - Exception in io.confluent.kafka.schemaregistry.rest.exceptions: Indicates an invalid schema that does not conform to the expected format of the schema
RestInvalidSchemaException() - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidSchemaException
RestInvalidSchemaException(String) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidSchemaException
RestInvalidSubjectException - Exception in io.confluent.kafka.schemaregistry.rest.exceptions: Indicates an invalid subject name
RestInvalidSubjectException(String) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidSubjectException
RestInvalidVersionException - Exception in io.confluent.kafka.schemaregistry.rest.exceptions: Indicates that the version is not a valid version id.
RestInvalidVersionException(String) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestInvalidVersionException
RestOperationNotPermittedException - Exception in io.confluent.kafka.schemaregistry.rest.exceptions
RestOperationNotPermittedException(String) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestOperationNotPermittedException
RestReferenceExistsException - Exception in io.confluent.kafka.schemaregistry.rest.exceptions: Indicates a reference exists to the given schema, so it cannot be deleted.
RestReferenceExistsException(String) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestReferenceExistsException
RestRequestForwardingException - Exception in io.confluent.kafka.schemaregistry.rest.exceptions: Indicates a problem while forwarding the request to the leader node in a schema registry cluster
RestRequestForwardingException(String) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestRequestForwardingException
RestRequestForwardingException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestRequestForwardingException
RestSchemaRegistryException - Exception in io.confluent.kafka.schemaregistry.rest.exceptions: Indicates some error while performing a schema registry operation
RestSchemaRegistryException(String) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestSchemaRegistryException
RestSchemaRegistryException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestSchemaRegistryException
RestSchemaRegistryStoreException - Exception in io.confluent.kafka.schemaregistry.rest.exceptions: Indicates an error while performing an operation on the underlying data store that stores all schemas in the registry
RestSchemaRegistryStoreException(String) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestSchemaRegistryStoreException
RestSchemaRegistryStoreException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestSchemaRegistryStoreException
RestSchemaRegistryTimeoutException - Exception in io.confluent.kafka.schemaregistry.rest.exceptions: Indicates that some schema registry operation timed out.
RestSchemaRegistryTimeoutException(String) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestSchemaRegistryTimeoutException
RestSchemaRegistryTimeoutException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestSchemaRegistryTimeoutException
RestSchemaTooLargeException - Exception in io.confluent.kafka.schemaregistry.rest.exceptions
RestSchemaTooLargeException(String) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestSchemaTooLargeException
RestUnknownLeaderException - Exception in io.confluent.kafka.schemaregistry.rest.exceptions
RestUnknownLeaderException(String) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestUnknownLeaderException
RestUnknownLeaderException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.rest.exceptions.RestUnknownLeaderException
ROLLBACK_FAILURE - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.StoreUpdateHandler.ValidationStatus
RootResource - Class in io.confluent.kafka.schemaregistry.rest.resources
RootResource() - Constructor for class io.confluent.kafka.schemaregistry.rest.resources.RootResource
Rule - Class in io.confluent.kafka.schemaregistry.storage
Rule(Rule) - Constructor for class io.confluent.kafka.schemaregistry.storage.Rule
Rule(String, String, RuleKind, RuleMode, String, SortedSet<String>, SortedMap<String, String>, String, String, String, boolean) - Constructor for class io.confluent.kafka.schemaregistry.storage.Rule
RuleKind - Enum Class in io.confluent.kafka.schemaregistry.storage
RuleMode - Enum Class in io.confluent.kafka.schemaregistry.storage
RuleSet - Class in io.confluent.kafka.schemaregistry.storage: Rule set, which includes migration rules (for migrating between versions), domain rules (for business logic), and encoding rules (for encoding logic).
RuleSet(RuleSet) - Constructor for class io.confluent.kafka.schemaregistry.storage.RuleSet
RuleSet(List<Rule>, List<Rule>, List<Rule>, ExecutionEnvironment) - Constructor for class io.confluent.kafka.schemaregistry.storage.RuleSet
ruleSetHandler - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
RuleSetHandler - Class in io.confluent.kafka.schemaregistry.storage
RuleSetHandler() - Constructor for class io.confluent.kafka.schemaregistry.storage.RuleSetHandler
run() - Method in class io.confluent.kafka.schemaregistry.utils.ShutdownableThread
runningFast(int, float) - Method in class io.confluent.kafka.schemaregistry.tools.SchemaRegistryPerformance

S

schema() - Method in class io.confluent.kafka.schemaregistry.storage.LazyParsedSchemaHolder: Returns the schema.
SCHEMA - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKeyType
SCHEMA_CACHE_EXPIRY_SECS_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: schema.cache.expiry.secs
SCHEMA_CACHE_EXPIRY_SECS_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SCHEMA_CACHE_EXPIRY_SECS_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SCHEMA_CACHE_SIZE_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: schema.cache.size
SCHEMA_CACHE_SIZE_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SCHEMA_CACHE_SIZE_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SCHEMA_CANONICALIZE_ON_CONSUME_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: schema.canonicalize.on.consume
SCHEMA_CANONICALIZE_ON_CONSUME_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SCHEMA_COMPATIBILITY_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SCHEMA_NOT_FOUND_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SCHEMA_NOT_FOUND_MESSAGE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SCHEMA_NOT_FOUND_MESSAGE_FORMAT - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SCHEMA_PROVIDERS_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SCHEMA_PROVIDERS_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SCHEMA_REGISTRY - Static variable in interface io.confluent.kafka.schemaregistry.storage.StoreUpdateHandler
SCHEMA_SEARCH_DEFAULT_LIMIT_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: schema.search.default.limit
SCHEMA_SEARCH_DEFAULT_LIMIT_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SCHEMA_SEARCH_DEFAULT_LIMIT_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SCHEMA_SEARCH_MAX_LIMIT_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: schema.search.max.limit
SCHEMA_SEARCH_MAX_LIMIT_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SCHEMA_SEARCH_MAX_LIMIT_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SCHEMA_TOO_LARGE_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SCHEMA_VALIDATE_FIELDS_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SCHEMA_VALIDATE_FIELDS_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SCHEMA_VALIDATE_NEW_SCHEMAS_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SCHEMA_VALIDATE_NEW_SCHEMAS_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SCHEMA$ - Static variable in class otherns.Subrecord
schemaDeleted(SchemaKey, SchemaValue, SchemaValue) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
schemaDeleted(SchemaKey, SchemaValue, SchemaValue) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Callback that is invoked when a schema is deleted.
schemaIdAndSubjects(Schema) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
schemaIdAndSubjects(Schema) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Provides SchemaIdAndSubjects associated with the schema.
SchemaIdAndSubjects - Class in io.confluent.kafka.schemaregistry.storage: Kafka schema registry maintains a few in memory indices to facilitate schema lookups.
SchemaIdAndSubjects(int) - Constructor for class io.confluent.kafka.schemaregistry.storage.SchemaIdAndSubjects
SchemaIdAndSubjects(int, Map<String, Integer>) - Constructor for class io.confluent.kafka.schemaregistry.storage.SchemaIdAndSubjects
SchemaIdRange - Class in io.confluent.kafka.schemaregistry.id: A range of schema IDs, from the first available ID to the inclusive upper bound.
SchemaIdRange(int, int) - Constructor for class io.confluent.kafka.schemaregistry.id.SchemaIdRange
SchemaKey - Class in io.confluent.kafka.schemaregistry.storage
SchemaKey(String, int) - Constructor for class io.confluent.kafka.schemaregistry.storage.SchemaKey
schemaKeyById(Integer, String) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
schemaKeyById(Integer, String) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Provides the SchemaKey for the provided schema id.
schemaNotFoundException() - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
schemaNotFoundException(Integer) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
schemaNotFoundException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
schemaProvider(String) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
schemaProvider(String) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
SchemaReference - Class in io.confluent.kafka.schemaregistry.storage
SchemaReference(SchemaReference) - Constructor for class io.confluent.kafka.schemaregistry.storage.SchemaReference
SchemaReference(String, String, Integer) - Constructor for class io.confluent.kafka.schemaregistry.storage.SchemaReference
schemaRegistered(SchemaKey, SchemaValue) - Method in interface io.confluent.kafka.schemaregistry.id.IdGenerator: Callback method that is invoked when a schema is registered.
schemaRegistered(SchemaKey, SchemaValue) - Method in class io.confluent.kafka.schemaregistry.id.IncrementalIdGenerator
schemaRegistered(SchemaKey, SchemaValue, SchemaValue) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
schemaRegistered(SchemaKey, SchemaValue, SchemaValue) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Callback that is invoked when a schema is registered.
schemaRegistry() - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication
SchemaRegistry - Interface in io.confluent.kafka.schemaregistry.storage
SCHEMAREGISTRY_GROUP_ID_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SCHEMAREGISTRY_GROUP_ID_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SCHEMAREGISTRY_INTER_INSTANCE_PROTOCOL_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: Deprecated.
SCHEMAREGISTRY_INTER_INSTANCE_PROTOCOL_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SCHEMAREGISTRY_RESOURCE_EXTENSION_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: Deprecated.
SCHEMAREGISTRY_RESOURCE_EXTENSION_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SchemaRegistryClientPerformance - Class in io.confluent.kafka.schemaregistry.tools
SchemaRegistryClientPerformance(String, String, long, long, String) - Constructor for class io.confluent.kafka.schemaregistry.tools.SchemaRegistryClientPerformance
SchemaRegistryConfig - Class in io.confluent.kafka.schemaregistry.rest
SchemaRegistryConfig(String) - Constructor for class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SchemaRegistryConfig(Properties) - Constructor for class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SchemaRegistryConfig(ConfigDef, Properties) - Constructor for class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
schemaRegistryException(String, Throwable) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SchemaRegistryException - Exception in io.confluent.kafka.schemaregistry.exceptions: Indicates some error while performing a schema registry operation
SchemaRegistryException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryException
SchemaRegistryException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryException
SchemaRegistryException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryException
SchemaRegistryException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryException
SchemaRegistryIdentity - Class in io.confluent.kafka.schemaregistry.storage: The identity of a schema registry instance.
SchemaRegistryIdentity(String, Integer, Boolean, String) - Constructor for class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
SchemaRegistryInitializationException - Exception in io.confluent.kafka.schemaregistry.exceptions: Indicates an error while initializing schema registry
SchemaRegistryInitializationException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryInitializationException
SchemaRegistryInitializationException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryInitializationException
SchemaRegistryInitializationException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryInitializationException
SchemaRegistryInitializationException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryInitializationException
SchemaRegistryKey - Class in io.confluent.kafka.schemaregistry.storage
SchemaRegistryKey(SchemaRegistryKeyType) - Constructor for class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKey
SchemaRegistryKeyType - Enum Class in io.confluent.kafka.schemaregistry.storage
SchemaRegistryMain - Class in io.confluent.kafka.schemaregistry.rest
SchemaRegistryMain() - Constructor for class io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain
SchemaRegistryMetric - Class in io.confluent.kafka.schemaregistry.metrics
SchemaRegistryMetric(Metrics, String, MetricName, MeasurableStat) - Constructor for class io.confluent.kafka.schemaregistry.metrics.SchemaRegistryMetric
SchemaRegistryPerformance - Class in io.confluent.kafka.schemaregistry.tools
SchemaRegistryPerformance(String, String, long, long, String) - Constructor for class io.confluent.kafka.schemaregistry.tools.SchemaRegistryPerformance
SchemaRegistryRequestForwardingException - Exception in io.confluent.kafka.schemaregistry.exceptions: Indicates an error while forwarding a write request to the leader node in a schema registry cluster
SchemaRegistryRequestForwardingException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryRequestForwardingException
SchemaRegistryRequestForwardingException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryRequestForwardingException
SchemaRegistryRequestForwardingException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryRequestForwardingException
SchemaRegistryRequestForwardingException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryRequestForwardingException
SchemaRegistryResourceExtension - Interface in io.confluent.kafka.schemaregistry.rest.extensions
SchemaRegistryRestApplication - Class in io.confluent.kafka.schemaregistry.rest
SchemaRegistryRestApplication(SchemaRegistryConfig) - Constructor for class io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication
SchemaRegistryRestApplication(SchemaRegistryConfig, X509Source) - Constructor for class io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication
SchemaRegistryRestApplication(Properties) - Constructor for class io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication
SchemaRegistrySerializer - Class in io.confluent.kafka.schemaregistry.storage.serialization
SchemaRegistrySerializer() - Constructor for class io.confluent.kafka.schemaregistry.storage.serialization.SchemaRegistrySerializer
SchemaRegistryStoreException - Exception in io.confluent.kafka.schemaregistry.exceptions: Indicates an error while performing an operation on the underlying data store that stores all schemas in the registry
SchemaRegistryStoreException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryStoreException
SchemaRegistryStoreException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryStoreException
SchemaRegistryStoreException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryStoreException
SchemaRegistryStoreException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryStoreException
SchemaRegistryTimeoutException - Exception in io.confluent.kafka.schemaregistry.exceptions: Indicates that some schema registry operation timed out.
SchemaRegistryTimeoutException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryTimeoutException
SchemaRegistryTimeoutException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryTimeoutException
SchemaRegistryTimeoutException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryTimeoutException
SchemaRegistryTimeoutException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryTimeoutException
SchemaRegistryValue - Class in io.confluent.kafka.schemaregistry.storage
SchemaRegistryValue() - Constructor for class io.confluent.kafka.schemaregistry.storage.SchemaRegistryValue
schemaSearchDefaultLimit - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
schemaSearchMaxLimit - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
SchemasResource - Class in io.confluent.kafka.schemaregistry.rest.resources
SchemasResource(SchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.rest.resources.SchemasResource
schemaTombstoned(SchemaKey, SchemaValue) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
schemaTombstoned(SchemaKey, SchemaValue) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Callback that is invoked when a schema is tombstoned.
schemaTooLargeException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SchemaTooLargeException - Exception in io.confluent.kafka.schemaregistry.exceptions
SchemaTooLargeException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaTooLargeException
SchemaTooLargeException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaTooLargeException
SchemaTooLargeException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaTooLargeException
SchemaTooLargeException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaTooLargeException
schemaTypes() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
schemaTypes() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
SchemaUpdateHandler - Interface in io.confluent.kafka.schemaregistry.storage
schemaValue() - Method in class io.confluent.kafka.schemaregistry.storage.LazyParsedSchemaHolder
schemaValue() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaValueHolder: Returns the schema value.
SchemaValue - Class in io.confluent.kafka.schemaregistry.storage
SchemaValue(Schema) - Constructor for class io.confluent.kafka.schemaregistry.storage.SchemaValue
SchemaValue(Schema, RuleSetHandler) - Constructor for class io.confluent.kafka.schemaregistry.storage.SchemaValue
SchemaValue(String, Integer, Integer, String, boolean) - Constructor for class io.confluent.kafka.schemaregistry.storage.SchemaValue
SchemaValue(String, Integer, Integer, String, String, List<SchemaReference>, Metadata, RuleSet, String, boolean) - Constructor for class io.confluent.kafka.schemaregistry.storage.SchemaValue
SchemaValue(String, Integer, Integer, String, List<SchemaReference>, String, boolean) - Constructor for class io.confluent.kafka.schemaregistry.storage.SchemaValue
SchemaValueHolder - Interface in io.confluent.kafka.schemaregistry.storage: An extension of ParsedSchemaHolder that also provides access to the underlying SchemaValue.
SCHEMAVERSION_NOT_SOFT_DELETED_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SCHEMAVERSION_NOT_SOFT_DELETED_MESSAGE_FORMAT - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SCHEMAVERSION_SOFT_DELETED_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SCHEMAVERSION_SOFT_DELETED_MESSAGE_FORMAT - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
schemaVersionExists(String, VersionId, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
schemaVersionExists(String, VersionId, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
schemaVersionNotSoftDeletedException(String, String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SchemaVersionNotSoftDeletedException - Exception in io.confluent.kafka.schemaregistry.exceptions
SchemaVersionNotSoftDeletedException(String, String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaVersionNotSoftDeletedException
schemaVersionSoftDeletedException(String, String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
scheme - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry.SchemeAndPort
SchemeAndPort(String, int) - Constructor for class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry.SchemeAndPort
SerializationException - Exception in io.confluent.kafka.schemaregistry.storage.exceptions: Error while (de)serializing data while reading from or writing to a * io.confluent.kafka.schemaregistry.storage.Store
SerializationException() - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.SerializationException
SerializationException(String) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.SerializationException
SerializationException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.SerializationException
SerializationException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.SerializationException
serialize(String, KeysetWrapper) - Method in class io.confluent.kafka.schemaregistry.storage.encoder.KeysetWrapperSerializer
serializeKey(SchemaRegistryKey) - Method in class io.confluent.kafka.schemaregistry.storage.serialization.SchemaRegistrySerializer
serializeKey(K) - Method in interface io.confluent.kafka.schemaregistry.storage.serialization.Serializer
serializer() - Method in class io.confluent.kafka.schemaregistry.storage.encoder.KeysetWrapperSerde
Serializer<K,V> - Interface in io.confluent.kafka.schemaregistry.storage.serialization
serializeValue(SchemaRegistryValue) - Method in class io.confluent.kafka.schemaregistry.storage.serialization.SchemaRegistrySerializer
serializeValue(V) - Method in interface io.confluent.kafka.schemaregistry.storage.serialization.Serializer
SERVER - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.ExecutionEnvironment
ServerMetadataResource - Class in io.confluent.kafka.schemaregistry.rest.resources
ServerMetadataResource(SchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.rest.resources.ServerMetadataResource
setAlias(String) - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
setAliasForDeks(String) - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
setAssociationType(String) - Method in class io.confluent.kafka.schemaregistry.storage.AssociationKey
setAssociationType(String) - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
setCompatibilityGroup(String) - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
setCompatibilityLevel(CompatibilityLevel) - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
setCompatibilityPolicy(CompatibilityPolicy) - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
setContext(String) - Method in class io.confluent.kafka.schemaregistry.storage.ContextKey
setContext(String) - Method in class io.confluent.kafka.schemaregistry.storage.ContextValue
setCreateTimestamp(Long) - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
setDefaultMetadata(Metadata) - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
setDefaultRuleSet(RuleSet) - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
setDeleted(boolean) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
setField2(CharSequence) - Method in class otherns.Subrecord.Builder: Sets the value of the 'field2' field.
setField2(CharSequence) - Method in class otherns.Subrecord: Sets the value of the 'field2' field.
setFrozen(boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
setGuid(String) - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
setHost(String) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
setId(Integer) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
setKeyType(SchemaRegistryKeyType) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKey
setLastOffset(String, long) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore
setLeader(SchemaRegistryIdentity) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry: 'Inform' this SchemaRegistry instance which SchemaRegistry is the current leader.
setLeader(SchemaRegistryIdentity) - Method in interface io.confluent.kafka.schemaregistry.storage.LeaderAwareSchemaRegistry
setLeader(SchemaRegistryIdentity) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
setLeader(Boolean) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
setLeaderEligibility(Boolean) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
setLifecycle(Lifecycle) - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
setMagicByte(int) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKey
setMd5(String) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
setMd5Bytes(byte[]) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
setMetadata(Metadata) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
setMode(Mode) - Method in class io.confluent.kafka.schemaregistry.storage.ModeValue
setMode(String) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
setMode(String, ModeUpdateRequest) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
setMode(String, ModeUpdateRequest) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
setMode(String, ModeUpdateRequest, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
setMode(String, ModeUpdateRequest, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
setMode(String, String) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
setMode(String, String, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
setModeOrForward(String, ModeUpdateRequest, boolean, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
setModeOrForward(String, ModeUpdateRequest, boolean, Map<String, String>) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
setName(String) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaReference
setNormalize(Boolean) - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
setOffset(Long) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryValue
setOverrideMetadata(Metadata) - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
setOverrideRuleSet(RuleSet) - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
setPort(Integer) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
setReferences(List<SchemaReference>) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
setResourceId(String) - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
setResourceName(String) - Method in class io.confluent.kafka.schemaregistry.storage.AssociationKey
setResourceName(String) - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
setResourceNamespace(String) - Method in class io.confluent.kafka.schemaregistry.storage.AssociationKey
setResourceNamespace(String) - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
setResourceType(String) - Method in class io.confluent.kafka.schemaregistry.storage.AssociationKey
setResourceType(String) - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
setRuleSet(RuleSet) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
setRuleSetHandler(RuleSetHandler) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
setRuleSetHandler(RuleSetHandler) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
setSchema(String) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
setSchemaType(String) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
setScheme(String) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
setSubject(String) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaReference
setSubject(String) - Method in class io.confluent.kafka.schemaregistry.storage.SubjectKey
setSubject(String) - Method in class io.confluent.kafka.schemaregistry.storage.SubjectValue
setTenant(String) - Method in class io.confluent.kafka.schemaregistry.storage.AssociationKey
setTenant(String) - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
setTenant(String) - Method in class io.confluent.kafka.schemaregistry.storage.ContextKey
setTenant(String) - Method in class io.confluent.kafka.schemaregistry.storage.ContextValue
setTenant(String) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Can be used by subclasses to implement multi-tenancy
setTenant(String) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry: Can be used by subclasses to implement multi-tenancy
setTimestamp(Long) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryValue
setUpLockFile(File) - Method in class io.confluent.kafka.schemaregistry.storage.OffsetCheckpoint
setUpLockFile(File) - Method in class io.confluent.kafka.schemaregistry.storage.OffsetCheckpointReadOnly
setupResources(Configurable<?>, SchemaRegistryConfig) - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication
setValidateFields(Boolean) - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
setValidateNewSchemas(Boolean) - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
setValidateRules(Boolean) - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
setVersion(int) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaKey
setVersion(Integer) - Method in class io.confluent.kafka.schemaregistry.storage.DeleteSubjectValue
setVersion(Integer) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaReference
setVersion(Integer) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
setVersion(Integer) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
shutdown() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStoreReaderThread
shutdown() - Method in class io.confluent.kafka.schemaregistry.utils.ShutdownableThread
ShutdownableThread - Class in io.confluent.kafka.schemaregistry.utils
ShutdownableThread(String) - Constructor for class io.confluent.kafka.schemaregistry.utils.ShutdownableThread
ShutdownableThread(String, boolean) - Constructor for class io.confluent.kafka.schemaregistry.utils.ShutdownableThread
ShutdownableThread(String, boolean, String) - Constructor for class io.confluent.kafka.schemaregistry.utils.ShutdownableThread
sslFactory - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
startBatch(int) - Method in class io.confluent.kafka.schemaregistry.storage.CompositeSchemaUpdateHandler
startBatch(int) - Method in interface io.confluent.kafka.schemaregistry.storage.StoreUpdateHandler: Invoked before a batch of updates.
store - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
Store<K,V> - Interface in io.confluent.kafka.schemaregistry.storage
STORE_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
storeException(String, Throwable) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
StoreException - Exception in io.confluent.kafka.schemaregistry.storage.exceptions: Error while performing an operation on a * io.confluent.kafka.schemaregistry.storage.Store
StoreException() - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.StoreException
StoreException(String) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.StoreException
StoreException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.StoreException
StoreException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.StoreException
StoreInitializationException - Exception in io.confluent.kafka.schemaregistry.storage.exceptions: Error while initializing a io.confluent.kafka.schemaregistry.storage.Store
StoreInitializationException() - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.StoreInitializationException
StoreInitializationException(String) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.StoreInitializationException
StoreInitializationException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.StoreInitializationException
StoreInitializationException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.StoreInitializationException
StoreTimeoutException - Exception in io.confluent.kafka.schemaregistry.storage.exceptions: Indicates either a write, read or a bootstrap operation on the underlying Kafka store timed out.
StoreTimeoutException(String) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.StoreTimeoutException
StoreTimeoutException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.StoreTimeoutException
StoreUpdateHandler<K,V> - Interface in io.confluent.kafka.schemaregistry.storage
StoreUpdateHandler.ValidationStatus - Enum Class in io.confluent.kafka.schemaregistry.storage
STRONG - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.Lifecycle
STRONG_ASSOCIATION_FOR_SUBJECT_EXISTS_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
STRONG_ASSOCIATION_FOR_SUBJECT_EXISTS_MESSAGE_FORMAT - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
strongAssociationExistsException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
StrongAssociationForSubjectExistsException - Exception in io.confluent.kafka.schemaregistry.exceptions
StrongAssociationForSubjectExistsException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.StrongAssociationForSubjectExistsException
StrongAssociationForSubjectExistsException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.StrongAssociationForSubjectExistsException
StrongAssociationForSubjectExistsException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.StrongAssociationForSubjectExistsException
StrongAssociationForSubjectExistsException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.StrongAssociationForSubjectExistsException
SUBJECT_LEVEL_COMPATIBILITY_NOT_CONFIGURED_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SUBJECT_LEVEL_COMPATIBILITY_NOT_CONFIGURED_MESSAGE_FORMAT - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SUBJECT_LEVEL_MODE_NOT_CONFIGURED_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SUBJECT_LEVEL_MODE_NOT_CONFIGURED_MESSAGE_FORMAT - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SUBJECT_NOT_FOUND_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SUBJECT_NOT_FOUND_MESSAGE_FORMAT - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SUBJECT_NOT_SOFT_DELETED_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SUBJECT_NOT_SOFT_DELETED_MESSAGE_FORMAT - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SUBJECT_SEARCH_DEFAULT_LIMIT_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: subject.search.default.limit
SUBJECT_SEARCH_DEFAULT_LIMIT_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SUBJECT_SEARCH_DEFAULT_LIMIT_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SUBJECT_SEARCH_MAX_LIMIT_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: subject.search.max.limit
SUBJECT_SEARCH_MAX_LIMIT_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SUBJECT_SEARCH_MAX_LIMIT_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SUBJECT_SOFT_DELETED_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SUBJECT_SOFT_DELETED_MESSAGE_FORMAT - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SUBJECT_VERSION_SEARCH_DEFAULT_LIMIT_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: subject.version.search.default.limit
SUBJECT_VERSION_SEARCH_DEFAULT_LIMIT_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SUBJECT_VERSION_SEARCH_DEFAULT_LIMIT_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SUBJECT_VERSION_SEARCH_MAX_LIMIT_CONFIG - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig: subject.version.search.max.limit
SUBJECT_VERSION_SEARCH_MAX_LIMIT_DEFAULT - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SUBJECT_VERSION_SEARCH_MAX_LIMIT_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
SubjectKey - Class in io.confluent.kafka.schemaregistry.storage
SubjectKey(SchemaRegistryKeyType, String) - Constructor for class io.confluent.kafka.schemaregistry.storage.SubjectKey
SubjectKeyComparator<K> - Class in io.confluent.kafka.schemaregistry.storage
SubjectKeyComparator() - Constructor for class io.confluent.kafka.schemaregistry.storage.SubjectKeyComparator
SubjectKeyComparator(LookupCache<K, ?>) - Constructor for class io.confluent.kafka.schemaregistry.storage.SubjectKeyComparator
subjectLevelCompatibilityNotConfiguredException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
subjectLevelModeNotConfiguredException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
subjectNotFoundException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
subjectNotSoftDeletedException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SubjectNotSoftDeletedException - Exception in io.confluent.kafka.schemaregistry.exceptions
SubjectNotSoftDeletedException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SubjectNotSoftDeletedException
subjects(String, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
subjects(String, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache
subjects(String, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache: Returns subjects that have schemas (that are not deleted) that match the given subject.
subjects(String, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
subjectSearchDefaultLimit - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
subjectSearchMaxLimit - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
subjectSoftDeletedException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
SubjectsResource - Class in io.confluent.kafka.schemaregistry.rest.resources
SubjectsResource(SchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.rest.resources.SubjectsResource
SubjectValue - Class in io.confluent.kafka.schemaregistry.storage
SubjectValue(String) - Constructor for class io.confluent.kafka.schemaregistry.storage.SubjectValue
subjectVersionSearchDefaultLimit - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
subjectVersionSearchMaxLimit - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
SubjectVersionsResource - Class in io.confluent.kafka.schemaregistry.rest.resources
SubjectVersionsResource(SchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.rest.resources.SubjectVersionsResource
Subrecord - Class in otherns
Subrecord() - Constructor for class otherns.Subrecord: Default constructor.
Subrecord(CharSequence) - Constructor for class otherns.Subrecord: All-args constructor.
Subrecord.Builder - Class in otherns: RecordBuilder for Subrecord instances.
SUCCESS - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.StoreUpdateHandler.ValidationStatus

T

tenant() - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache
tenant() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
testCompatibility(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
testCompatibilityBySubjectName(AsyncResponse, String, String, boolean, RegisterSchemaRequest, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.CompatibilityResource
testCompatibilityForSubject(AsyncResponse, String, boolean, RegisterSchemaRequest, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.CompatibilityResource
testCompatibilityVerbose(String, ParsedSchema) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
time - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
timestamp - Variable in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryValue
toAssociationEntity() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
toByteBuffer() - Method in class otherns.Subrecord: Serializes this Subrecord to a ByteBuffer.
toConfigEntity() - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
toEntity() - Method in enum class io.confluent.kafka.schemaregistry.storage.ExecutionEnvironment
toEntity() - Method in enum class io.confluent.kafka.schemaregistry.storage.RuleKind
toEntity() - Method in enum class io.confluent.kafka.schemaregistry.storage.RuleMode
toHashKey() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
toJson() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
toJsonBytes() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
toKey() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
toKey() - Method in class io.confluent.kafka.schemaregistry.storage.ClearSubjectValue
toKey() - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
toKey() - Method in class io.confluent.kafka.schemaregistry.storage.DeleteSubjectValue
toKey() - Method in class io.confluent.kafka.schemaregistry.storage.ModeValue
toKey() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
toKey() - Method in class io.confluent.kafka.schemaregistry.storage.SubjectValue
toLifecyclePolicy() - Method in enum class io.confluent.kafka.schemaregistry.storage.Lifecycle
toMetadataEntity() - Method in class io.confluent.kafka.schemaregistry.storage.Metadata
TOO_MANY_ASSOCIATIONS_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
TOO_MANY_ASSOCIATIONS_MESSAGE_FORMAT - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
tooManyAssociationsException(int) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
TooManyAssociationsException - Exception in io.confluent.kafka.schemaregistry.exceptions
TooManyAssociationsException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.TooManyAssociationsException
TooManyAssociationsException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.TooManyAssociationsException
TooManyAssociationsException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.TooManyAssociationsException
TooManyAssociationsException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.TooManyAssociationsException
toRefEntity() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaReference
toResponse(EofException) - Method in class io.confluent.kafka.schemaregistry.rest.exceptions.JettyEofExceptionMapper
toRuleEntity() - Method in class io.confluent.kafka.schemaregistry.storage.Rule
toRuleSetEntity() - Method in class io.confluent.kafka.schemaregistry.storage.RuleSet
toSchemaEntity() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
toSchemaEntity(SchemaValue) - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
toSchemaEntity(SchemaValue) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
toString() - Method in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry.RawSchema
toString() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationKey
toString() - Method in class io.confluent.kafka.schemaregistry.storage.AssociationValue
toString() - Method in class io.confluent.kafka.schemaregistry.storage.ClearSubjectKey
toString() - Method in class io.confluent.kafka.schemaregistry.storage.ClearSubjectValue
toString() - Method in class io.confluent.kafka.schemaregistry.storage.ConfigKey
toString() - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
toString() - Method in class io.confluent.kafka.schemaregistry.storage.DeleteSubjectKey
toString() - Method in class io.confluent.kafka.schemaregistry.storage.DeleteSubjectValue
toString() - Method in class io.confluent.kafka.schemaregistry.storage.MD5
toString() - Method in class io.confluent.kafka.schemaregistry.storage.Metadata
toString() - Method in class io.confluent.kafka.schemaregistry.storage.ModeKey
toString() - Method in class io.confluent.kafka.schemaregistry.storage.ModeValue
toString() - Method in class io.confluent.kafka.schemaregistry.storage.NoopKey
toString() - Method in class io.confluent.kafka.schemaregistry.storage.OffsetCheckpoint
toString() - Method in class io.confluent.kafka.schemaregistry.storage.Rule
toString() - Method in class io.confluent.kafka.schemaregistry.storage.RuleSet
toString() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaIdAndSubjects
toString() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaKey
toString() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaReference
toString() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
toString() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue
transform(RuleSet) - Method in class io.confluent.kafka.schemaregistry.storage.RuleSetHandler
transform(CloseableIterator<F>, Function<? super F, ? extends T>) - Static method in class io.confluent.kafka.schemaregistry.storage.TransformedIterator
TRANSFORM - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.RuleKind
TransformedIterator<F,T> - Class in io.confluent.kafka.schemaregistry.storage

U

UNKNOWN_LEADER_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
unknownLeaderException(String, Throwable) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
UnknownLeaderException - Exception in io.confluent.kafka.schemaregistry.exceptions: Indicates that the node that is asked to serve the request is not the current leader and is not aware of the leader node to forward the request to
UnknownLeaderException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.UnknownLeaderException
UnknownLeaderException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.UnknownLeaderException
UnknownLeaderException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.UnknownLeaderException
UnknownLeaderException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.UnknownLeaderException
update(String, ConfigValue, ConfigUpdateRequest, RuleSetHandler) - Static method in class io.confluent.kafka.schemaregistry.storage.ConfigValue
updateConfig(String, Config) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient
updateConfig(String, ConfigUpdateRequest) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
updateConfig(String, ConfigUpdateRequest) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
updateConfigOrForward(String, ConfigUpdateRequest, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
updateConfigOrForward(String, ConfigUpdateRequest, Map<String, String>) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry
updateMode(String, HttpHeaders, ModeUpdateRequest, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.ModeResource
UpdateRequestHandler - Interface in io.confluent.kafka.schemaregistry.rest.handlers
updateRequestHandlers - Variable in class io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry
updateSubjectLevelConfig(String, HttpHeaders, ConfigUpdateRequest) - Method in class io.confluent.kafka.schemaregistry.rest.resources.ConfigResource
updateTopLevelConfig(HttpHeaders, ConfigUpdateRequest) - Method in class io.confluent.kafka.schemaregistry.rest.resources.ConfigResource
updateTopLevelMode(HttpHeaders, ModeUpdateRequest, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.ModeResource
UPDOWN - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.RuleMode
UPGRADE - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.RuleMode

V

VALIDATE_FIELDS_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
VALIDATE_NEW_SCHEMAS_DOC - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
validateUpdate(SchemaRegistryKey, SchemaRegistryValue, TopicPartition, long, long) - Method in class io.confluent.kafka.schemaregistry.storage.CompositeSchemaUpdateHandler: Invoked before every new K,V pair written to the store
validateUpdate(SchemaRegistryKey, SchemaRegistryValue, TopicPartition, long, long) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStoreMessageHandler: Invoked before every new K,V pair written to the store
validateUpdate(K, V, TopicPartition, long, long) - Method in interface io.confluent.kafka.schemaregistry.storage.StoreUpdateHandler: Invoked before every new K,V pair written to the store
value() - Element in annotation interface io.confluent.kafka.schemaregistry.rest.resources.DocumentedName
valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.storage.ExecutionEnvironment: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.storage.Lifecycle: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.storage.LookupFilter: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.storage.Mode: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.storage.RuleKind: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.storage.RuleMode: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKeyType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.storage.StoreUpdateHandler.ValidationStatus: Returns the enum constant of this class with the specified name.
values() - Static method in enum class io.confluent.kafka.schemaregistry.storage.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.storage.Lifecycle: 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.storage.LookupFilter: 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.storage.Mode: 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.storage.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.storage.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.storage.SchemaRegistryKeyType: 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.storage.StoreUpdateHandler.ValidationStatus: Returns an array containing the constants of this enum class, in the order they are declared.
VERSION_NOT_FOUND_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
VERSION_NOT_FOUND_MESSAGE_FORMAT - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors
VersionId - Class in io.confluent.kafka.schemaregistry.rest: A valid version id should be a positive integer between 1 and 2^31-1.
VersionId(int) - Constructor for class io.confluent.kafka.schemaregistry.rest.VersionId
VersionId(String) - Constructor for class io.confluent.kafka.schemaregistry.rest.VersionId
versionNotFoundException(Integer) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors

W

waitForInit() - Method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService
waitForInit() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry
waitForInit() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore
waitUntilKafkaReaderReachesLastOffset(int) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore: Wait until the KafkaStore catches up to the last message in the Kafka topic.
waitUntilKafkaReaderReachesLastOffset(String, int) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore: Wait until the KafkaStore catches up to the last message for the given subject.
waitUntilOffset(long, long, TimeUnit) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStoreReaderThread
WEAK - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.Lifecycle
whitelistHeaders() - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig
write(Map<TopicPartition, Long>) - Method in class io.confluent.kafka.schemaregistry.storage.OffsetCheckpoint: Write the given offsets to the checkpoint file.
write(Map<TopicPartition, Long>) - Method in class io.confluent.kafka.schemaregistry.storage.OffsetCheckpointReadOnly
WRITE - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.RuleMode
writeErrorJson(Request, PrintWriter, int, String, Throwable, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.JsonErrorHandler
writeExternal(ObjectOutput) - Method in class otherns.Subrecord
WRITEREAD - Enum constant in enum class io.confluent.kafka.schemaregistry.storage.RuleMode

X

X_FORWARDED_FOR_HEADER - Static variable in class io.confluent.kafka.schemaregistry.rest.RequestHeaderHandler
X_REQUEST_ID_HEADER - Static variable in class io.confluent.kafka.schemaregistry.rest.RequestHeaderHandler

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