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

A

addLeaderChangeListener(Consumer<Boolean>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

Add a leader change listener.

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.KafkaSchemaRegistry

AliasFilter - Class in io.confluent.kafka.schemaregistry.rest.filters

AliasFilter(KafkaSchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.rest.filters.AliasFilter

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.KafkaSchemaRegistry

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

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

checkBootstrapServers() - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig

checkIfSchemaWithIdExist(int, Schema) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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

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

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

clearField2() - Method in class otherns.Subrecord.Builder

Clears the value of the 'field2' field.

clearNewSchemaCache() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

clearOldSchemaCache() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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

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.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(SchemaRegistryKey) - Method in class io.confluent.kafka.schemaregistry.storage.ContextKey

compareTo(SchemaRegistryKey) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaKey

compareTo(SchemaReference) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaReference

compareTo(SchemaRegistryKey) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKey

compareTo(SchemaValue) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue

compareTo(SchemaRegistryKey) - Method in class io.confluent.kafka.schemaregistry.storage.SubjectKey

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(KafkaSchemaRegistry) - 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

config(String, boolean, Config) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache

config() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

config(String, boolean, Config) - Method in interface io.confluent.kafka.schemaregistry.storage.LookupCache

Retrieves the config for a subject.

config() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry

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(KafkaSchemaRegistry) - 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, ?>, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.encoder.KeysetWrapperSerde

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

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, String, Boolean, Boolean, Boolean, CompatibilityLevel, String, Metadata, Metadata, RuleSet, RuleSet) - Constructor for class io.confluent.kafka.schemaregistry.storage.ConfigValue

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

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.

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

ContextsResource - Class in io.confluent.kafka.schemaregistry.rest.resources

ContextsResource(KafkaSchemaRegistry) - 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

createCache(Serde<K>, Serde<V>, String, CacheUpdateHandler<K, V>) - Method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService

createDecoder(SchemaStore) - Static method in class otherns.Subrecord

Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore.

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

D

decodeMetadata(SchemaValue) - Method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService

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.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_TENANT - Static variable in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry

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(K) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache

delete(K) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore

delete() - Method in class io.confluent.kafka.schemaregistry.storage.OffsetCheckpoint

delete(K) - Method in interface io.confluent.kafka.schemaregistry.storage.Store

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

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

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

deleteSchemaVersionOrForward(Map<String, String>, String, Schema, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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

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

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.storage.KafkaSchemaRegistry

deleteSubject(String, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry

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

DeleteSubjectKey - Class in io.confluent.kafka.schemaregistry.storage

DeleteSubjectKey(String) - Constructor for class io.confluent.kafka.schemaregistry.storage.DeleteSubjectKey

deleteSubjectMode(AsyncResponse, HttpHeaders, String) - Method in class io.confluent.kafka.schemaregistry.rest.resources.ModeResource

deleteSubjectMode(String) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

deleteSubjectModeOrForward(String, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

deleteSubjectOrForward(Map<String, String>, String, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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 Type in io.confluent.kafka.schemaregistry.rest.resources

doIteration(PerformanceStats.Callback) - Method in class io.confluent.kafka.schemaregistry.tools.SchemaRegistryClientPerformance

doIteration(PerformanceStats.Callback) - Method in class io.confluent.kafka.schemaregistry.tools.SchemaRegistryPerformance

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

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

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

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.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

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.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

extractSchemaTags(Schema, List<String>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

F

file - Variable in class io.confluent.kafka.schemaregistry.storage.OffsetCheckpoint

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

filter(CloseableIterator<T>, Predicate<? super T>) - Static method in class io.confluent.kafka.schemaregistry.storage.FilteredIterator

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 io.confluent.kafka.schemaregistry.storage.SchemaRegistryKeyType

forwardModifySchemaTagsRequestToLeader(String, Schema, TagSchemaRequest, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

fromByteBuffer(ByteBuffer) - Static method in class otherns.Subrecord

Deserializes a Subrecord from a ByteBuffer.

fromEntity(RuleKind) - Static method in enum io.confluent.kafka.schemaregistry.storage.RuleKind

fromEntity(RuleMode) - Static method in enum 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

G

get() - Method in class io.confluent.kafka.schemaregistry.rest.resources.RootResource

get(K) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache

get(String, int, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

get(int, String) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

get(int, String, String, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

get(K) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore

get(String, int, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry

get(int, String) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry

get(K) - Method in interface io.confluent.kafka.schemaregistry.storage.Store

get(int) - Method in class otherns.Subrecord

getAlias() - 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

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

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

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

getAllVersions(String, LookupFilter) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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

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

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

getCompositeUpdateRequestHandler() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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

getConfig(String) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

getConfigInScope(String) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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

getCurrentVersion() - Static method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity

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

getEncoder(String) - Method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService

getEncoder() - Static method in class otherns.Subrecord

Return the BinaryMessageEncoder instance used by this class.

getEncoders() - Method in class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService

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

getHeader(String) - Method in class io.confluent.kafka.schemaregistry.rest.MutableHttpServletRequest

getHeaderNames() - Method in class io.confluent.kafka.schemaregistry.rest.MutableHttpServletRequest

Get the unique (case-insensitive) header names in customHeaders and HttpServletRequest.

getHeaders(String) - Method in class io.confluent.kafka.schemaregistry.rest.MutableHttpServletRequest

getHost() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity

getHostnameVerifier() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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

getId() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue

getIdentityGenerator() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

getInterInstanceListener(List<NamedURI>, String, String) - Static method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

This method returns a listener to be used for inter-instance communication.

getKafkaClusterId() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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.KafkaSchemaRegistry

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.KafkaSchemaRegistry

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

getLookupCache() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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.KafkaSchemaRegistry

getMetrics() - Method in class io.confluent.kafka.schemaregistry.metrics.MetricsContainer

getMetricsContainer() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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(String) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient

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

getMode(String) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

getMode() - Method in class io.confluent.kafka.schemaregistry.storage.ModeValue

getMode() - Method in class io.confluent.kafka.schemaregistry.storage.Rule

getModeInScope(String) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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

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(String, String) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SubjectVersionsResource

getReferencedBy(String, VersionId) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

getReferences() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue

getRequestId(List<String>) - Method in class io.confluent.kafka.schemaregistry.rest.RequestIdHandler

getResourceExtensions() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

getRuleSet() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue

getRuleSetHandler() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

getSchema(Integer, String, String, List<String>, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SchemasResource

getSchema() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue

getSchema() - Method in class otherns.Subrecord

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, 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, 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.KafkaSchemaRegistry

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.KafkaSchemaRegistry

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.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) - 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.ContextKey

getTenant() - Method in class io.confluent.kafka.schemaregistry.storage.ContextValue

getTimestamp() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryValue

getTopLevelConfig() - Method in class io.confluent.kafka.schemaregistry.rest.resources.ConfigResource

getTopLevelMode() - 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.KafkaSchemaRegistry

getVersion() - Method in exception io.confluent.kafka.schemaregistry.exceptions.SchemaVersionNotSoftDeletedException

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

getVersion() - Method in class io.confluent.kafka.schemaregistry.storage.DeleteSubjectValue

getVersion(String) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaIdAndSubjects

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

getVersionId() - Method in class io.confluent.kafka.schemaregistry.rest.VersionId

getVersions(Integer, String, boolean) - 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.KafkaSchemaRegistry

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(String, ConfigUpdateRequest) - Method in class io.confluent.kafka.schemaregistry.rest.handlers.CompositeUpdateRequestHandler

handle(String, boolean, RegisterSchemaRequest) - Method in class io.confluent.kafka.schemaregistry.rest.handlers.CompositeUpdateRequestHandler

handle(Schema, TagSchemaRequest) - Method in class io.confluent.kafka.schemaregistry.rest.handlers.CompositeUpdateRequestHandler

handle(ConfigUpdateRequest, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.rest.handlers.CompositeUpdateRequestHandler

handle(String, ConfigUpdateRequest, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.rest.handlers.CompositeUpdateRequestHandler

handle(String, boolean, RegisterSchemaRequest, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.rest.handlers.CompositeUpdateRequestHandler

handle(Schema, TagSchemaRequest, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.rest.handlers.CompositeUpdateRequestHandler

handle(ConfigUpdateRequest) - Method in interface io.confluent.kafka.schemaregistry.rest.handlers.UpdateRequestHandler

handle(String, ConfigUpdateRequest) - Method in interface io.confluent.kafka.schemaregistry.rest.handlers.UpdateRequestHandler

handle(String, boolean, RegisterSchemaRequest) - Method in interface io.confluent.kafka.schemaregistry.rest.handlers.UpdateRequestHandler

handle(Schema, TagSchemaRequest) - Method in interface io.confluent.kafka.schemaregistry.rest.handlers.UpdateRequestHandler

handle(ConfigUpdateRequest, Map<String, String>) - Method in interface io.confluent.kafka.schemaregistry.rest.handlers.UpdateRequestHandler

handle(String, ConfigUpdateRequest, Map<String, String>) - Method in interface io.confluent.kafka.schemaregistry.rest.handlers.UpdateRequestHandler

handle(String, boolean, RegisterSchemaRequest, Map<String, String>) - Method in interface io.confluent.kafka.schemaregistry.rest.handlers.UpdateRequestHandler

handle(Schema, TagSchemaRequest, Map<String, String>) - Method in interface io.confluent.kafka.schemaregistry.rest.handlers.UpdateRequestHandler

handle(String, Request, HttpServletRequest, HttpServletResponse) - Method in class io.confluent.kafka.schemaregistry.rest.JsonErrorHandler

handle(String, Request, HttpServletRequest, HttpServletResponse) - Method in class io.confluent.kafka.schemaregistry.rest.RequestIdHandler

handle(String, ConfigUpdateRequest) - Method in class io.confluent.kafka.schemaregistry.storage.RuleSetHandler

handle(String, boolean, RegisterSchemaRequest) - Method in class io.confluent.kafka.schemaregistry.storage.RuleSetHandler

handle(Schema, TagSchemaRequest) - Method in class io.confluent.kafka.schemaregistry.storage.RuleSetHandler

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.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

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.InMemoryCache

hasSubjects(String, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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.

healthy() - Method in interface io.confluent.kafka.schemaregistry.rest.extensions.SchemaRegistryResourceExtension

healthy() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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

IdDoesNotMatchException - Exception in io.confluent.kafka.schemaregistry.exceptions

Indicates a schema already exists with a different ID.

IdDoesNotMatchException(int, int) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IdDoesNotMatchException

IdDoesNotMatchException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IdDoesNotMatchException

IdDoesNotMatchException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IdDoesNotMatchException

IdDoesNotMatchException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IdDoesNotMatchException

IdDoesNotMatchException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IdDoesNotMatchException

idDoesNotMatchException(Throwable) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors

identityGenerator(SchemaRegistryConfig) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

IdGenerationException - Exception in io.confluent.kafka.schemaregistry.exceptions

IdGenerationException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IdGenerationException

IdGenerationException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IdGenerationException

IdGenerationException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IdGenerationException

IdGenerationException() - 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.

INCOMPATIBLE_SCHEMA_ERROR_CODE - Static variable 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(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IncompatibleSchemaException

IncompatibleSchemaException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IncompatibleSchemaException

IncompatibleSchemaException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IncompatibleSchemaException

IncompatibleSchemaException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.IncompatibleSchemaException

incompatibleSchemaException(String, Throwable) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors

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

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_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() - 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

initiateShutdown() - Method in class io.confluent.kafka.schemaregistry.utils.ShutdownableThread

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_COMPATIBILITY_LEVEL_ERROR_CODE - Static variable in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors

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

invalidateFromNewSchemaCache(Schema) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

Invalidate the cached parsed schema for a new schema.

invalidateFromOldSchemaCache(Schema) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

Invalidate the cached parsed schema for an old schema.

InvalidSchemaException - Exception in io.confluent.kafka.schemaregistry.exceptions

Indicates an invalid schema that does not conform to the expected format of the schema

InvalidSchemaException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.InvalidSchemaException

InvalidSchemaException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.InvalidSchemaException

InvalidSchemaException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.InvalidSchemaException

InvalidSchemaException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.InvalidSchemaException

invalidSchemaException(Throwable) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors

invalidSubjectException(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(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.InvalidVersionException

InvalidVersionException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.InvalidVersionException

InvalidVersionException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.InvalidVersionException

InvalidVersionException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.InvalidVersionException

invalidVersionException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors

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.KafkaSchemaRegistry

isCompatible(String, Schema, List<SchemaKey>, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry

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

isLatest() - Method in class io.confluent.kafka.schemaregistry.rest.VersionId

isLeader() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

isLeader() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity

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.

isRotationNeeded() - Method in class io.confluent.kafka.schemaregistry.storage.encoder.KeysetWrapper

isRunning() - Method in class io.confluent.kafka.schemaregistry.utils.ShutdownableThread

isShutdownComplete() - Method in class io.confluent.kafka.schemaregistry.utils.ShutdownableThread

isShutdownInitiated() - Method in class io.confluent.kafka.schemaregistry.utils.ShutdownableThread

isThreadFailed() - Method in class io.confluent.kafka.schemaregistry.utils.ShutdownableThread

isValidateFields() - 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, KafkaSchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.leaderelector.kafka.KafkaGroupLeaderElector

KafkaSchemaRegistry - Class in io.confluent.kafka.schemaregistry.storage

KafkaSchemaRegistry(SchemaRegistryConfig, Serializer<SchemaRegistryKey, SchemaRegistryValue>) - Constructor for class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

KafkaSchemaRegistry.SchemeAndPort - Class in io.confluent.kafka.schemaregistry.storage

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_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(KafkaSchemaRegistry, 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

keyType - Variable in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKey

keyType - Variable in enum 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(KafkaSchemaRegistry, 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.

leaderLock() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaStore

leaderRestService() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

list(String, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SubjectsResource

listContexts() - Method in class io.confluent.kafka.schemaregistry.rest.resources.ContextsResource

listContexts() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

LISTENER_NAME_PREFIX - Static variable in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig

listSubjects(LookupFilter) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

listSubjects() - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry

listSubjects(LookupFilter) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry

listSubjectsForId(int, String) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

listSubjectsForId(int, String, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

listSubjectsForId(int, String, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry

listSubjectsWithPrefix(String, LookupFilter) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

listVersions(String, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SubjectVersionsResource

listVersionsForId(int, String) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

listVersionsForId(int, String, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

LocalSchemaRegistryClient - Class in io.confluent.kafka.schemaregistry.rest.client

Local implementation of SchemaRegistryClient that can be used without going through HTTP.

LocalSchemaRegistryClient(KafkaSchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient

LocalSchemaRegistryClient(KafkaSchemaRegistry, 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

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 in io.confluent.kafka.schemaregistry.storage

lookUpSchemaUnderSubject(AsyncResponse, String, boolean, String, boolean, RegisterSchemaRequest) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SubjectsResource

lookUpSchemaUnderSubject(String, Schema, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

Checks if given schema was ever registered under a subject.

lookUpSchemaUnderSubject(String, Schema, boolean) - Method in interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry

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.KafkaSchemaRegistry

M

magicByte - Variable in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryKey

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.

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

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 class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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(SortedMap<String, SortedSet<String>>, SortedMap<String, String>, SortedSet<String>) - Constructor for class io.confluent.kafka.schemaregistry.storage.Metadata

Metadata(Metadata) - 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

MetadataEncoderService - Class in io.confluent.kafka.schemaregistry.storage.encoder

MetadataEncoderService(SchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService

MetadataEncoderService(SchemaRegistry, Cache<String, KeysetWrapper>) - Constructor for class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService

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 - Class in io.confluent.kafka.schemaregistry.metrics

MetricsContainer(SchemaRegistryConfig, String) - Constructor for class io.confluent.kafka.schemaregistry.metrics.MetricsContainer

MIN_VERSION - Static variable in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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 in io.confluent.kafka.schemaregistry.storage

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(KafkaSchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.rest.resources.ModeResource

ModeValue - Class in io.confluent.kafka.schemaregistry.storage

ModeValue(String, Mode) - Constructor for class io.confluent.kafka.schemaregistry.storage.ModeValue

ModeValue() - Constructor for class io.confluent.kafka.schemaregistry.storage.ModeValue

modifySchemaTags(String, Schema, TagSchemaRequest) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

modifySchemaTagsOrForward(String, Schema, TagSchemaRequest, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

modifyTags(AsyncResponse, HttpHeaders, String, String, TagSchemaRequest) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SubjectVersionsResource

MutableHttpServletRequest - Class in io.confluent.kafka.schemaregistry.rest

Allows for adding and replacing custom headers in the HttpServletRequest object.

MutableHttpServletRequest(HttpServletRequest) - Constructor for class io.confluent.kafka.schemaregistry.rest.MutableHttpServletRequest

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.

N

newBuilder() - Static method in class otherns.Subrecord

Creates a new Subrecord RecordBuilder.

newBuilder(Subrecord.Builder) - Static method in class otherns.Subrecord

Creates a new Subrecord RecordBuilder by copying an existing Builder.

newBuilder(Subrecord) - Static method in class otherns.Subrecord

Creates a new Subrecord RecordBuilder by copying an existing Subrecord instance.

next() - Method in class io.confluent.kafka.schemaregistry.storage.FilteredIterator

next() - Method in class io.confluent.kafka.schemaregistry.storage.TransformedIterator

NoopKey - Class in io.confluent.kafka.schemaregistry.storage

NoopKey() - Constructor for class io.confluent.kafka.schemaregistry.storage.NoopKey

normalizeLimit(int) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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

onAssigned(SchemaRegistryProtocol.Assignment, int) - Method in class io.confluent.kafka.schemaregistry.leaderelector.kafka.KafkaGroupLeaderElector

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

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 - Exception in io.confluent.kafka.schemaregistry.exceptions

The requested operation is not permitted.

OperationNotPermittedException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.OperationNotPermittedException

OperationNotPermittedException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.OperationNotPermittedException

OperationNotPermittedException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.OperationNotPermittedException

OperationNotPermittedException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.OperationNotPermittedException

operationNotPermittedException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors

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(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

parseSchema(Schema) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient

parseSchema(Schema) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

parseSchema(Schema, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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.KafkaSchemaRegistry.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

postServerStart() - Method in class io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication

properties() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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 - Class in io.confluent.kafka.schemaregistry.utils

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

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

put(int, Object) - Method in class otherns.Subrecord

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

putHeader(String, String) - Method in class io.confluent.kafka.schemaregistry.rest.MutableHttpServletRequest

Puts a new header will take precedence over existing header in the HttpServletRequest object.

R

read() - Method in class io.confluent.kafka.schemaregistry.storage.OffsetCheckpoint

Reads the offsets from the local checkpoint file, skipping any negative offsets it finds.

readExternal(ObjectInput) - Method in class otherns.Subrecord

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 - Exception in io.confluent.kafka.schemaregistry.exceptions

Indicates the schema cannot be deleted because another schema references it.

ReferenceExistsException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.ReferenceExistsException

ReferenceExistsException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.ReferenceExistsException

ReferenceExistsException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.ReferenceExistsException

ReferenceExistsException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.ReferenceExistsException

referenceExistsException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors

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(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

register(Configurable<?>, SchemaRegistryConfig, SchemaRegistry) - Method in interface io.confluent.kafka.schemaregistry.rest.extensions.SchemaRegistryResourceExtension

register(AsyncResponse, HttpHeaders, String, boolean, String, RegisterSchemaRequest) - Method in class io.confluent.kafka.schemaregistry.rest.resources.SubjectVersionsResource

register(String, RegisterSchemaRequest, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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) - 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 interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry

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

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

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

REQUEST_ID_HEADER - Static variable in class io.confluent.kafka.schemaregistry.rest.RequestIdHandler

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

RequestIdHandler - Class in io.confluent.kafka.schemaregistry.rest

RequestIdHandler() - Constructor for class io.confluent.kafka.schemaregistry.rest.RequestIdHandler

reset() - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient

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

RestCallMetricFilter - Class in io.confluent.kafka.schemaregistry.rest.filters

RestCallMetricFilter(SchemaRegistryMetric, SchemaRegistryMetric) - Constructor for class io.confluent.kafka.schemaregistry.rest.filters.RestCallMetricFilter

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

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

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(String, String, RuleKind, RuleMode, String, SortedSet<String>, SortedMap<String, String>, String, String, String, boolean) - Constructor for class io.confluent.kafka.schemaregistry.storage.Rule

Rule(Rule) - Constructor for class io.confluent.kafka.schemaregistry.storage.Rule

RuleKind - Enum in io.confluent.kafka.schemaregistry.storage

RuleMode - Enum in io.confluent.kafka.schemaregistry.storage

RuleSet - Class in io.confluent.kafka.schemaregistry.storage

Rule set, which includes migration rules (for migrating between versions) and domain rules (for the current version).

RuleSet(List<Rule>, List<Rule>) - Constructor for class io.confluent.kafka.schemaregistry.storage.RuleSet

RuleSet(RuleSet) - Constructor for class io.confluent.kafka.schemaregistry.storage.RuleSet

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$ - Static variable in class otherns.Subrecord

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

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

schemaProvider(String) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

SchemaReference - Class in io.confluent.kafka.schemaregistry.storage

SchemaReference(String, String, Integer) - Constructor for class io.confluent.kafka.schemaregistry.storage.SchemaReference

SchemaReference(SchemaReference) - 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 - Exception in io.confluent.kafka.schemaregistry.exceptions

Indicates some error while performing a schema registry operation

SchemaRegistryException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryException

SchemaRegistryException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryException

SchemaRegistryException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryException

SchemaRegistryException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryException

schemaRegistryException(String, Throwable) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors

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(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryInitializationException

SchemaRegistryInitializationException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryInitializationException

SchemaRegistryInitializationException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryInitializationException

SchemaRegistryInitializationException() - 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 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(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryRequestForwardingException

SchemaRegistryRequestForwardingException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryRequestForwardingException

SchemaRegistryRequestForwardingException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryRequestForwardingException

SchemaRegistryRequestForwardingException() - 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(Properties) - Constructor for class io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication

SchemaRegistryRestApplication(SchemaRegistryConfig) - 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(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryStoreException

SchemaRegistryStoreException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryStoreException

SchemaRegistryStoreException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryStoreException

SchemaRegistryStoreException() - 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(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryTimeoutException

SchemaRegistryTimeoutException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryTimeoutException

SchemaRegistryTimeoutException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryTimeoutException

SchemaRegistryTimeoutException() - 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

SchemasResource - Class in io.confluent.kafka.schemaregistry.rest.resources

SchemasResource(KafkaSchemaRegistry) - 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 - Exception in io.confluent.kafka.schemaregistry.exceptions

SchemaTooLargeException(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaTooLargeException

SchemaTooLargeException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaTooLargeException

SchemaTooLargeException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaTooLargeException

SchemaTooLargeException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaTooLargeException

schemaTooLargeException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors

schemaTypes() - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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 - Class in io.confluent.kafka.schemaregistry.storage

SchemaValue(String, Integer, Integer, 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

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

SchemaValue(Schema) - Constructor for class io.confluent.kafka.schemaregistry.storage.SchemaValue

SchemaValue(Schema, RuleSetHandler) - Constructor for class io.confluent.kafka.schemaregistry.storage.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.KafkaSchemaRegistry

SchemaVersionNotSoftDeletedException - Exception in io.confluent.kafka.schemaregistry.exceptions

SchemaVersionNotSoftDeletedException(String, String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SchemaVersionNotSoftDeletedException

schemaVersionNotSoftDeletedException(String, String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors

schemaVersionSoftDeletedException(String, String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors

scheme - Variable in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry.SchemeAndPort

SchemeAndPort(String, int) - Constructor for class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry.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(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.SerializationException

SerializationException(String) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.SerializationException

SerializationException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.SerializationException

SerializationException() - 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

ServerMetadataResource - Class in io.confluent.kafka.schemaregistry.rest.resources

ServerMetadataResource(KafkaSchemaRegistry) - Constructor for class io.confluent.kafka.schemaregistry.rest.resources.ServerMetadataResource

setAlias(String) - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue

setCompatibilityGroup(String) - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue

setCompatibilityLevel(CompatibilityLevel) - 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

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.

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(Boolean) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity

setLeaderEligibility(Boolean) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity

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(String) - Method in class io.confluent.kafka.schemaregistry.rest.client.LocalSchemaRegistryClient

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

setMode(String, Mode) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

setMode(String, Mode, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

setMode(Mode) - Method in class io.confluent.kafka.schemaregistry.storage.ModeValue

setModeOrForward(String, Mode, boolean, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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

setRuleSet(RuleSet) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue

setRuleSetHandler(RuleSetHandler) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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.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

setValidateRules(Boolean) - Method in class io.confluent.kafka.schemaregistry.storage.ConfigValue

setVersion(Integer) - Method in class io.confluent.kafka.schemaregistry.storage.DeleteSubjectValue

setVersion(int) - Method in class io.confluent.kafka.schemaregistry.storage.SchemaKey

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

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<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(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.StoreException

StoreException(String) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.StoreException

StoreException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.StoreException

StoreException() - 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(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.StoreInitializationException

StoreInitializationException(String) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.StoreInitializationException

StoreInitializationException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.storage.exceptions.StoreInitializationException

StoreInitializationException() - 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 in io.confluent.kafka.schemaregistry.storage

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_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

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 - Exception in io.confluent.kafka.schemaregistry.exceptions

SubjectNotSoftDeletedException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.SubjectNotSoftDeletedException

subjectNotSoftDeletedException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors

subjects(String, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.InMemoryCache

subjects(String, boolean) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

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.

subjectSoftDeletedException(String) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors

SubjectsResource - Class in io.confluent.kafka.schemaregistry.rest.resources

SubjectsResource(KafkaSchemaRegistry) - 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

SubjectVersionsResource - Class in io.confluent.kafka.schemaregistry.rest.resources

SubjectVersionsResource(KafkaSchemaRegistry) - 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.

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

timestamp - Variable in class io.confluent.kafka.schemaregistry.storage.SchemaRegistryValue

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 io.confluent.kafka.schemaregistry.storage.RuleKind

toEntity() - Method in enum 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.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

toMetadataEntity() - Method in class io.confluent.kafka.schemaregistry.storage.Metadata

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(SchemaValue) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

toSchemaEntity() - Method in class io.confluent.kafka.schemaregistry.storage.SchemaValue

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.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

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 - 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(String, Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.UnknownLeaderException

UnknownLeaderException(String) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.UnknownLeaderException

UnknownLeaderException(Throwable) - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.UnknownLeaderException

UnknownLeaderException() - Constructor for exception io.confluent.kafka.schemaregistry.exceptions.UnknownLeaderException

unknownLeaderException(String, Throwable) - Static method in class io.confluent.kafka.schemaregistry.rest.exceptions.Errors

update(ConfigValue, ConfigValue) - 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, Config) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

updateConfigOrForward(String, Config, Map<String, String>) - Method in class io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

updateMode(String, HttpHeaders, ModeUpdateRequest, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.resources.ModeResource

UpdateRequestHandler - Interface in io.confluent.kafka.schemaregistry.rest.handlers

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

V

VALIDATE_FIELDS_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

valueOf(String) - Static method in enum io.confluent.kafka.schemaregistry.storage.LookupFilter

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.confluent.kafka.schemaregistry.storage.Mode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.confluent.kafka.schemaregistry.storage.RuleKind

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.confluent.kafka.schemaregistry.storage.RuleMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.confluent.kafka.schemaregistry.storage.SchemaRegistryKeyType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.confluent.kafka.schemaregistry.storage.StoreUpdateHandler.ValidationStatus

Returns the enum constant of this type with the specified name.

values() - Static method in enum io.confluent.kafka.schemaregistry.storage.LookupFilter

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.confluent.kafka.schemaregistry.storage.Mode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.confluent.kafka.schemaregistry.storage.RuleKind

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.confluent.kafka.schemaregistry.storage.RuleMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.confluent.kafka.schemaregistry.storage.SchemaRegistryKeyType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.confluent.kafka.schemaregistry.storage.StoreUpdateHandler.ValidationStatus

Returns an array containing the constants of this enum type, 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(String) - Constructor for class io.confluent.kafka.schemaregistry.rest.VersionId

VersionId(int) - 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

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

writeErrorPage(HttpServletRequest, Writer, int, String, boolean) - Method in class io.confluent.kafka.schemaregistry.rest.JsonErrorHandler

writeExternal(ObjectOutput) - Method in class otherns.Subrecord

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