Uses of Class
io.confluent.kafka.schemaregistry.storage.exceptions.StoreException

Packages that use StoreException

Package	Description
io.confluent.kafka.schemaregistry.storage
io.confluent.kafka.schemaregistry.storage.exceptions

Uses of StoreException in io.confluent.kafka.schemaregistry.storage

Methods in io.confluent.kafka.schemaregistry.storage that throw StoreException

Modifier and Type	Method and Description
void	KafkaSchemaRegistry.checkIfSchemaWithIdExist(int id, Schema schema)
Map<String,Integer>	InMemoryCache.clearSubjects(String subject)
Map<String,Integer>	LookupCache.clearSubjects(String subject) Clears the cache of deleted schemas that match the given subject.
void	InMemoryCache.close()
void	Store.close()
default CompatibilityLevel	LookupCache.compatibilityLevel(String subject, boolean returnTopLevelIfNotFound, CompatibilityLevel defaultForTopLevel) Retrieves the config for a subject.
Config	InMemoryCache.config(String subject, boolean returnTopLevelIfNotFound, Config defaultForTopLevel)
Config	LookupCache.config(String subject, boolean returnTopLevelIfNotFound, Config defaultForTopLevel) Retrieves the config for a subject.
boolean	InMemoryCache.containsSchema(Schema schema)
boolean	LookupCache.containsSchema(Schema schema) Checks if a schema is registered in any subject.
V	InMemoryCache.delete(K key)
V	KafkaStore.delete(K key)
V	Store.delete(K key)
void	InMemoryCache.flush()
void	KafkaStore.flush()
void	Store.flush()
V	InMemoryCache.get(K key)
V	KafkaStore.get(K key)
V	Store.get(K key)
CloseableIterator<V>	InMemoryCache.getAll(K key1, K key2)
CloseableIterator<V>	KafkaStore.getAll(K key1, K key2)
CloseableIterator<V>	Store.getAll(K key1, K key2) Iterator over keys in the specified range
CloseableIterator<K>	InMemoryCache.getAllKeys()
CloseableIterator<K>	KafkaStore.getAllKeys()
CloseableIterator<K>	Store.getAllKeys()
boolean	InMemoryCache.hasSubjects(String subject, boolean lookupDeletedSubjects)
boolean	LookupCache.hasSubjects(String subject, boolean lookupDeletedSubjects) Returns whether there exist schemas (that are not deleted) that match the given subject.
Mode	InMemoryCache.mode(String subject, boolean returnTopLevelIfNotFound, Mode defaultForTopLevel)
Mode	LookupCache.mode(String subject, boolean returnTopLevelIfNotFound, Mode defaultForTopLevel) Retrieves the mode for a subject.
V	InMemoryCache.put(K key, V value)
V	KafkaStore.put(K key, V value)
V	Store.put(K key, V value)
void	InMemoryCache.putAll(Map<K,V> entries)
void	KafkaStore.putAll(Map<K,V> entries)
void	Store.putAll(Map<K,V> entries)
Set<Integer>	InMemoryCache.referencesSchema(SchemaKey schema)
Set<Integer>	LookupCache.referencesSchema(SchemaKey schema) Returns schemas that reference the given schema.
SchemaIdAndSubjects	InMemoryCache.schemaIdAndSubjects(Schema schema)
SchemaIdAndSubjects	LookupCache.schemaIdAndSubjects(Schema schema) Provides SchemaIdAndSubjects associated with the schema.
SchemaKey	InMemoryCache.schemaKeyById(Integer id, String subject)
SchemaKey	LookupCache.schemaKeyById(Integer id, String subject) Provides the SchemaKey for the provided schema id.
Set<String>	InMemoryCache.subjects(String subject, boolean lookupDeletedSubjects)
Set<String>	LookupCache.subjects(String subject, boolean lookupDeletedSubjects) Returns subjects that have schemas (that are not deleted) that match the given subject.
void	KafkaStore.waitUntilKafkaReaderReachesLastOffset(int timeoutMs) Wait until the KafkaStore catches up to the last message in the Kafka topic.
void	KafkaStore.waitUntilKafkaReaderReachesLastOffset(String subject, int timeoutMs) Wait until the KafkaStore catches up to the last message for the given subject.
void	KafkaStoreReaderThread.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.exceptions

Modifier and Type	Class and Description
class	EntryTooLargeException
class	StoreTimeoutException Indicates either a write, read or a bootstrap operation on the underlying Kafka store timed out.