Uses of Class
io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryException

Packages that use SchemaRegistryException

Package	Description
io.confluent.kafka.schemaregistry.exceptions
io.confluent.kafka.schemaregistry.rest.extensions
io.confluent.kafka.schemaregistry.rest.handlers
io.confluent.kafka.schemaregistry.storage

Uses of SchemaRegistryException in io.confluent.kafka.schemaregistry.exceptions

Subclasses of SchemaRegistryException in io.confluent.kafka.schemaregistry.exceptions

Modifier and Type	Class and Description
class	IdDoesNotMatchException Indicates a schema already exists with a different ID.
class	IdGenerationException
class	IncompatibleSchemaException Indicates the schema is incompatible with the registered schema
class	InvalidSchemaException Indicates an invalid schema that does not conform to the expected format of the schema
class	InvalidVersionException Indicates that the version is not a valid version id.
class	OperationNotPermittedException The requested operation is not permitted.
class	ReferenceExistsException Indicates the schema cannot be deleted because another schema references it.
class	SchemaRegistryInitializationException Indicates an error while initializing schema registry
class	SchemaRegistryRequestForwardingException Indicates an error while forwarding a write request to the leader node in a schema registry cluster
class	SchemaRegistryStoreException Indicates an error while performing an operation on the underlying data store that stores all schemas in the registry
class	SchemaRegistryTimeoutException Indicates that some schema registry operation timed out.
class	SchemaTooLargeException
class	SchemaVersionNotSoftDeletedException
class	SubjectNotSoftDeletedException
class	UnknownLeaderException 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

Uses of SchemaRegistryException in io.confluent.kafka.schemaregistry.rest.extensions

Methods in io.confluent.kafka.schemaregistry.rest.extensions that throw SchemaRegistryException

Modifier and Type	Method and Description
void	SchemaRegistryResourceExtension.register(javax.ws.rs.core.Configurable<?> config, SchemaRegistryConfig schemaRegistryConfig, SchemaRegistry schemaRegistry)

Uses of SchemaRegistryException in io.confluent.kafka.schemaregistry.rest.handlers

Methods in io.confluent.kafka.schemaregistry.rest.handlers that throw SchemaRegistryException

Modifier and Type	Method and Description
default void	UpdateRequestHandler.handle(ConfigUpdateRequest request, Map<String,String> headerProperties)
void	CompositeUpdateRequestHandler.handle(ConfigUpdateRequest request, Map<String,String> headerProperties)
default void	UpdateRequestHandler.handle(Schema schema, TagSchemaRequest request, Map<String,String> headerProperties)
void	CompositeUpdateRequestHandler.handle(Schema schema, TagSchemaRequest request, Map<String,String> headerProperties)
default void	UpdateRequestHandler.handle(String subject, boolean normalize, RegisterSchemaRequest request, Map<String,String> headerProperties)
void	CompositeUpdateRequestHandler.handle(String subject, boolean normalize, RegisterSchemaRequest request, Map<String,String> headerProperties)
default void	UpdateRequestHandler.handle(String subject, ConfigUpdateRequest request, Map<String,String> headerProperties)
void	CompositeUpdateRequestHandler.handle(String subject, ConfigUpdateRequest request, Map<String,String> headerProperties)

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

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

Modifier and Type	Method and Description
Iterator<ExtendedSchema>	KafkaSchemaRegistry.allVersionsIncludingAliasesWithSubjectPrefix(String prefix, LookupFilter filter, boolean returnLatestOnly, Predicate<Schema> postFilter)
void	KafkaSchemaRegistry.checkIfSchemaWithIdExist(int id, Schema schema)
void	KafkaSchemaRegistry.deleteSchemaVersion(String subject, Schema schema, boolean permanentDelete)
void	SchemaRegistry.deleteSchemaVersion(String subject, Schema schema, boolean permanentDelete)
void	KafkaSchemaRegistry.deleteSchemaVersionOrForward(Map<String,String> headerProperties, String subject, Schema schema, boolean permanentDelete)
List<Integer>	KafkaSchemaRegistry.deleteSubject(String subject, boolean permanentDelete)
List<Integer>	SchemaRegistry.deleteSubject(String subject, boolean permanentDelete)
List<Integer>	KafkaSchemaRegistry.deleteSubjectOrForward(Map<String,String> requestProperties, String subject, boolean permanentDelete)
void	KafkaSchemaRegistry.extractSchemaTags(Schema schema, List<String> tags)
SchemaString	KafkaSchemaRegistry.get(int id, String subject)
SchemaString	SchemaRegistry.get(int id, String subject)
SchemaString	KafkaSchemaRegistry.get(int id, String subject, String format, boolean fetchMaxId)
Schema	KafkaSchemaRegistry.get(String subject, int version, boolean returnDeletedSchema)
Schema	SchemaRegistry.get(String subject, int version, boolean returnDeletedSchema)
Iterator<SchemaKey>	KafkaSchemaRegistry.getAllVersions(String subject, LookupFilter filter)
Iterator<SchemaKey>	SchemaRegistry.getAllVersions(String subject, LookupFilter filter)
static io.confluent.rest.NamedURI	KafkaSchemaRegistry.getInterInstanceListener(List<io.confluent.rest.NamedURI> listeners, String interInstanceListenerName, String requestedScheme) This method returns a listener to be used for inter-instance communication.
Schema	KafkaSchemaRegistry.getLatestVersion(String subject)
Schema	SchemaRegistry.getLatestVersion(String subject)
Schema	KafkaSchemaRegistry.getLatestWithMetadata(String subject, Map<String,String> metadata, boolean lookupDeletedSchema)
Schema	SchemaRegistry.getLatestWithMetadata(String subject, Map<String,String> metadata, boolean lookupDeletedSchema)
List<Integer>	KafkaSchemaRegistry.getReferencedBy(String subject, VersionId versionId)
protected SchemaValue	KafkaSchemaRegistry.getSchemaValue(SchemaKey key)
Schema	KafkaSchemaRegistry.getUsingContexts(String subject, int version, boolean returnDeletedSchema)
Iterator<ExtendedSchema>	KafkaSchemaRegistry.getVersionsWithSubjectPrefix(String prefix, boolean includeAliases, LookupFilter filter, boolean returnLatestOnly, Predicate<Schema> postFilter)
Iterator<ExtendedSchema>	SchemaRegistry.getVersionsWithSubjectPrefix(String prefix, boolean includeAliases, LookupFilter filter, boolean latestOnly, Predicate<Schema> postFilter)
void	KafkaSchemaRegistry.init()
void	SchemaRegistry.init()
List<String>	KafkaSchemaRegistry.isCompatible(String subject, Schema newSchema, List<SchemaKey> previousSchemas, boolean normalize)
List<String>	SchemaRegistry.isCompatible(String subject, Schema newSchema, List<SchemaKey> previousSchemas, boolean normalize)
protected KafkaStore<SchemaRegistryKey,SchemaRegistryValue>	KafkaSchemaRegistry.kafkaStore(SchemaRegistryConfig config)
List<String>	KafkaSchemaRegistry.listContexts()
default Set<String>	SchemaRegistry.listSubjects()
Set<String>	KafkaSchemaRegistry.listSubjects(LookupFilter filter)
Set<String>	SchemaRegistry.listSubjects(LookupFilter filter)
Set<String>	KafkaSchemaRegistry.listSubjectsForId(int id, String subject)
Set<String>	KafkaSchemaRegistry.listSubjectsForId(int id, String subject, boolean returnDeleted)
Set<String>	SchemaRegistry.listSubjectsForId(int id, String subject, boolean returnDeleted)
Set<String>	KafkaSchemaRegistry.listSubjectsWithPrefix(String prefix, LookupFilter filter)
List<SubjectVersion>	KafkaSchemaRegistry.listVersionsForId(int id, String subject)
List<SubjectVersion>	KafkaSchemaRegistry.listVersionsForId(int id, String subject, boolean lookupDeleted)
default Schema	SchemaRegistry.lookUpSchemaUnderSubject(String subject, Schema schema, boolean lookupDeletedSchema)
Schema	KafkaSchemaRegistry.lookUpSchemaUnderSubject(String subject, Schema schema, boolean normalize, boolean lookupDeletedSchema) Checks if given schema was ever registered under a subject.
Schema	SchemaRegistry.lookUpSchemaUnderSubject(String subject, Schema schema, boolean normalize, boolean lookupDeletedSchema)
Schema	KafkaSchemaRegistry.lookUpSchemaUnderSubjectUsingContexts(String subject, Schema schema, boolean normalize, boolean lookupDeletedSchema)
Schema	KafkaSchemaRegistry.modifySchemaTags(String subject, Schema schema, TagSchemaRequest request)
Schema	KafkaSchemaRegistry.modifySchemaTagsOrForward(String subject, Schema schema, TagSchemaRequest request, Map<String,String> headerProperties)
void	KafkaSchemaRegistry.postInit()
Schema	KafkaSchemaRegistry.register(String subject, RegisterSchemaRequest request, boolean normalize)
default Schema	SchemaRegistry.register(String subject, Schema schema)
default Schema	SchemaRegistry.register(String subject, Schema schema, boolean normalize)
Schema	KafkaSchemaRegistry.register(String subject, Schema schema, boolean normalize, boolean propagateSchemaTags) Register the given schema under the given subject.
Schema	SchemaRegistry.register(String subject, Schema schema, boolean normalize, boolean propagateSchemaTags)
Schema	KafkaSchemaRegistry.registerOrForward(String subject, RegisterSchemaRequest request, boolean normalize, Map<String,String> headerProperties)
SchemaValue	LazyParsedSchemaHolder.schemaValue()
boolean	KafkaSchemaRegistry.schemaVersionExists(String subject, VersionId versionId, boolean returnDeletedSchema)
void	KafkaSchemaRegistry.setMode(String subject, Mode mode)
void	KafkaSchemaRegistry.setMode(String subject, Mode mode, boolean force)
void	KafkaSchemaRegistry.setModeOrForward(String subject, Mode mode, boolean force, Map<String,String> headerProperties)

Constructors in io.confluent.kafka.schemaregistry.storage that throw SchemaRegistryException

Constructor and Description
KafkaSchemaRegistry(SchemaRegistryConfig config, Serializer<SchemaRegistryKey,SchemaRegistryValue> serializer)
KafkaStore(SchemaRegistryConfig config, StoreUpdateHandler<K,V> storeUpdateHandler, Serializer<K,V> serializer, Store<K,V> localStore, K noopKey)