Uses of Class
io.confluent.kafka.schemaregistry.storage.exceptions.StoreException
Packages that use StoreException
Package
Description
-
Uses of StoreException in io.confluent.kafka.schemaregistry.storage
Methods in io.confluent.kafka.schemaregistry.storage that throw StoreExceptionModifier and TypeMethodDescriptionInMemoryCache.associationByGuid(String guid) LookupCache.associationByGuid(String guid) Returns the association for the given association guid.InMemoryCache.associationsByResourceId(String resourceId) LookupCache.associationsByResourceId(String resourceId) Returns associations for the given resource id.InMemoryCache.associationsBySubject(String subject) LookupCache.associationsBySubject(String subject) Returns associations for the given subject.voidAbstractSchemaRegistry.checkIfSchemaWithIdExist(int id, Schema schema) InMemoryCache.clearSubjects(String subject) LookupCache.clearSubjects(String subject) Clears the cache of deleted schemas that match the given subject.voidInMemoryCache.close()voidStore.close()default CompatibilityLevelLookupCache.compatibilityLevel(String subject, boolean returnTopLevelIfNotFound, CompatibilityLevel defaultForTopLevel) Retrieves the config for a subject.Retrieves the config for a subject.booleanInMemoryCache.containsSchema(Schema schema) booleanLookupCache.containsSchema(Schema schema) Checks if a schema is registered in any subject.voidInMemoryCache.flush()voidKafkaStore.flush()voidStore.flush()Iterator over keys in the specified rangeInMemoryCache.getAllKeys()KafkaStore.getAllKeys()Store.getAllKeys()AbstractSchemaRegistry.getReferencedBy(SchemaKey key, boolean lookupDeletedSchema) booleanInMemoryCache.hasSubjects(String subject, boolean lookupDeletedSubjects) booleanLookupCache.hasSubjects(String subject, boolean lookupDeletedSubjects) Returns whether there exist schemas (that are not deleted) that match the given subject.Provides the id for the provided guid and context.Retrieves the mode for a subject.voidvoidvoidInMemoryCache.referencesSchema(SchemaKey schema) LookupCache.referencesSchema(SchemaKey schema) Returns schemas that reference the given schema.InMemoryCache.schemaIdAndSubjects(Schema schema) LookupCache.schemaIdAndSubjects(Schema schema) Provides SchemaIdAndSubjects associated with the schema.InMemoryCache.schemaKeyById(Integer id, String subject) LookupCache.schemaKeyById(Integer id, String subject) Provides theSchemaKeyfor the provided schema id.Returns subjects that have schemas (that are not deleted) that match the given subject.voidKafkaStore.waitUntilKafkaReaderReachesLastOffset(int timeoutMs) Wait until the KafkaStore catches up to the last message in the Kafka topic.voidKafkaStore.waitUntilKafkaReaderReachesLastOffset(String subject, int timeoutMs) Wait until the KafkaStore catches up to the last message for the given subject.voidKafkaStoreReaderThread.waitUntilOffset(long offset, long timeout, TimeUnit timeUnit) -
Uses of StoreException in io.confluent.kafka.schemaregistry.storage.exceptions
Subclasses of StoreException in io.confluent.kafka.schemaregistry.storage.exceptionsModifier and TypeClassDescriptionclassclassIndicates either a write, read or a bootstrap operation on the underlying Kafka store timed out.