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	Description
class	AssociationBatchLimitExceededException
class	AssociationForResourceExistsException
class	AssociationForSubjectExistsException
class	AssociationFrozenException
class	AssociationNotFoundException
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	NoActiveSubjectVersionExistsException
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	StrongAssociationForSubjectExistsException
class	SubjectNotFoundException
class	SubjectNotSoftDeletedException
class	SubjectSoftDeletedException
class	TooManyAssociationsException
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	Description
void	SchemaRegistryResourceExtension.register(jakarta.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	Description
void	CompositeUpdateRequestHandler.handle(ConfigUpdateRequest request, Map<String,String> headerProperties)
void	CompositeUpdateRequestHandler.handle(Schema schema, TagSchemaRequest request, Map<String,String> headerProperties)
void	CompositeUpdateRequestHandler.handle(String subject, boolean normalize, RegisterSchemaRequest request, Map<String,String> headerProperties)
void	CompositeUpdateRequestHandler.handle(String subject, ConfigUpdateRequest request, Map<String,String> headerProperties)
default void	UpdateRequestHandler.handle(ConfigUpdateRequest request, Map<String,String> headerProperties)
default void	UpdateRequestHandler.handle(Schema schema, TagSchemaRequest request, Map<String,String> headerProperties)
default void	UpdateRequestHandler.handle(String subject, boolean normalize, RegisterSchemaRequest request, Map<String,String> headerProperties)
default void	UpdateRequestHandler.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	Description
protected CloseableIterator<SchemaRegistryValue>	AbstractSchemaRegistry.allContexts()
Iterator<ExtendedSchema>	AbstractSchemaRegistry.allVersionsIncludingAliasesWithSubjectPrefix(String prefix, LookupFilter filter, boolean returnLatestOnly, Predicate<Schema> postFilter)
AssociationBatchResponse	AbstractSchemaRegistry.batchGetAssociations(boolean includeSchemas, AssociationBatchGetRequest request)
default AssociationBatchResponse	SchemaRegistry.batchGetAssociations(boolean includeSchemas, AssociationBatchGetRequest request)
protected ParsedSchema	AbstractSchemaRegistry.canonicalizeSchema(Schema schema, Config config, boolean validateAsNew, boolean normalize)
protected void	AbstractSchemaRegistry.checkDeleteAssociation(Association oldAssociation, boolean cascadeLifecycle)
void	AbstractSchemaRegistry.checkIfSchemaWithIdExist(int id, Schema schema)
AssociationResponse	AbstractSchemaRegistry.createAssociation(String context, boolean dryRun, AssociationCreateOrUpdateRequest request)
default AssociationResponse	SchemaRegistry.createAssociation(String context, boolean dryRun, AssociationCreateOrUpdateRequest request)
AssociationResponse	KafkaSchemaRegistry.createAssociationOrForward(String context, boolean dryRun, AssociationCreateOrUpdateRequest request, Map<String,String> headerProperties)
default AssociationResponse	SchemaRegistry.createAssociationOrForward(String context, boolean dryRun, AssociationCreateOrUpdateRequest request, Map<String,String> headerProperties)
AssociationResponse	AbstractSchemaRegistry.createOrUpdateAssociation(String context, boolean dryRun, AssociationCreateOrUpdateRequest request)
AssociationResponse	AbstractSchemaRegistry.createOrUpdateAssociation(String context, boolean dryRun, AssociationCreateOrUpdateRequest request, boolean isCreate)
default AssociationResponse	SchemaRegistry.createOrUpdateAssociation(String context, boolean dryRun, AssociationCreateOrUpdateRequest request)
AssociationResponse	KafkaSchemaRegistry.createOrUpdateAssociationOrForward(String context, boolean dryRun, AssociationCreateOrUpdateRequest request, Map<String,String> headerProperties)
default AssociationResponse	SchemaRegistry.createOrUpdateAssociationOrForward(String context, boolean dryRun, AssociationCreateOrUpdateRequest request, Map<String,String> headerProperties)
protected void	AbstractSchemaRegistry.deleteAssociationEntry(Association oldAssociation)
protected void	KafkaSchemaRegistry.deleteAssociationEntry(Association oldAssociation)
void	AbstractSchemaRegistry.deleteAssociations(String resourceId, String resourceType, List<String> associationTypes, boolean cascadeLifecycle, boolean dryRun)
default void	SchemaRegistry.deleteAssociations(String resourceId, String resourceType, List<String> associationTypes, boolean cascadeLifecycle)
void	KafkaSchemaRegistry.deleteAssociationsOrForward(String subject, String resourceId, String resourceType, List<String> associationTypes, boolean cascadeLifecycle, boolean dryRun, Map<String,String> headerProperties)
default void	SchemaRegistry.deleteAssociationsOrForward(String subject, String resourceId, String resourceType, List<String> associationTypes, boolean cascadeLifecycle, boolean dryRun, Map<String,String> headerProperties)
void	KafkaSchemaRegistry.deleteContext(String delimitedContext)
void	SchemaRegistry.deleteContext(String delimitedContext)
void	KafkaSchemaRegistry.deleteContextOrForward(Map<String,String> requestProperties, String delimitedContext)
default void	SchemaRegistry.deleteContextOrForward(Map<String,String> requestProperties, String delimitedContext)
int	KafkaSchemaRegistry.deleteSchemaVersion(String subject, int version, boolean permanentDelete)
int	SchemaRegistry.deleteSchemaVersion(String subject, int version, boolean permanentDelete)
int	KafkaSchemaRegistry.deleteSchemaVersionOrForward(Map<String,String> requestProperties, String subject, int version, boolean permanentDelete)
default int	SchemaRegistry.deleteSchemaVersionOrForward(Map<String,String> requestProperties, String subject, int version, 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)
default List<Integer>	SchemaRegistry.deleteSubjectOrForward(Map<String,String> requestProperties, String subject, boolean permanentDelete)
void	AbstractSchemaRegistry.extractSchemaTags(Schema schema, List<String> tags)
void	SchemaRegistry.extractSchemaTags(Schema schema, List<String> tags)
SchemaString	AbstractSchemaRegistry.get(int id, String subject)
Schema	AbstractSchemaRegistry.get(String subject, int version, boolean returnDeletedSchema)
SchemaString	KafkaSchemaRegistry.get(int id, String subject, String format, boolean fetchMaxId)
SchemaString	SchemaRegistry.get(int id, String subject)
SchemaString	SchemaRegistry.get(int id, String subject, String format, boolean fetchMaxId)
Schema	SchemaRegistry.get(String subject, int version, boolean returnDeletedSchema)
protected List<SchemaKey>	AbstractSchemaRegistry.getAllSchemaKeysDescending(String subject)
Iterator<SchemaKey>	AbstractSchemaRegistry.getAllVersions(String subject, LookupFilter filter)
Iterator<SchemaKey>	SchemaRegistry.getAllVersions(String subject, LookupFilter filter)
Association	AbstractSchemaRegistry.getAssociationByGuid(String guid)
default Association	SchemaRegistry.getAssociationByGuid(String guid)
List<Association>	AbstractSchemaRegistry.getAssociationsByResourceId(String resourceId, String resourceType, List<String> associationTypes, LifecyclePolicy lifecycle)
default List<Association>	SchemaRegistry.getAssociationsByResourceId(String resourceId, String resourceType, List<String> associationTypes, LifecyclePolicy lifecycle)
List<Association>	AbstractSchemaRegistry.getAssociationsByResourceName(String resourceName, String resourceNamespace, String resourceType, List<String> associationTypes, LifecyclePolicy lifecycle)
default List<Association>	SchemaRegistry.getAssociationsByResourceName(String resourceName, String resourceNamespace, String resourceType, List<String> associationTypes, LifecyclePolicy lifecycle)
List<Association>	AbstractSchemaRegistry.getAssociationsByResourceNamespace(String resourceNamespace, String resourceType, List<String> associationTypes, LifecyclePolicy lifecycle)
default List<Association>	SchemaRegistry.getAssociationsByResourceNamespace(String resourceNamespace, String resourceType, List<String> associationTypes, LifecyclePolicy lifecycle)
List<Association>	AbstractSchemaRegistry.getAssociationsBySubject(String subject, String resourceType, List<String> associationTypes, LifecyclePolicy lifecycle)
default List<Association>	SchemaRegistry.getAssociationsBySubject(String subject, String resourceType, List<String> associationTypes, LifecyclePolicy lifecycle)
SchemaString	AbstractSchemaRegistry.getByGuid(String guid, String format)
SchemaString	SchemaRegistry.getByGuid(String guid, String format)
static io.confluent.rest.NamedURI	AbstractSchemaRegistry.getInterInstanceListener(List<io.confluent.rest.NamedURI> listeners, String interInstanceListenerName, String requestedScheme)	This method returns a listener to be used for inter-instance communication.
Schema	AbstractSchemaRegistry.getLatestVersion(String subject)
Schema	SchemaRegistry.getLatestVersion(String subject)
Schema	AbstractSchemaRegistry.getLatestWithMetadata(String subject, Map<String,String> metadata, boolean lookupDeletedSchema)
Schema	SchemaRegistry.getLatestWithMetadata(String subject, Map<String,String> metadata, boolean lookupDeletedSchema)
protected Set<ContextId>	AbstractSchemaRegistry.getReferencedBy(SchemaKey key, boolean lookupDeletedSchema)
List<ContextId>	AbstractSchemaRegistry.getReferencedBy(String subject, VersionId versionId, boolean lookupDeletedSchema)
List<ContextId>	SchemaRegistry.getReferencedBy(String subject, VersionId versionId, boolean lookupDeletedSchema)
protected Set<String>	AbstractSchemaRegistry.getReferencedBySubjects(SchemaKey key, boolean lookupDeletedSchema)	Returns the set of subjects that have at least one schema version referencing the given key.
SchemaValue	AbstractSchemaRegistry.getSchemaValue(SchemaKey key)
SchemaValue	SchemaRegistry.getSchemaValue(SchemaKey key)
Schema	AbstractSchemaRegistry.getUsingContexts(String subject, int version, boolean returnDeletedSchema)
Schema	SchemaRegistry.getUsingContexts(String subject, int version, boolean returnDeletedSchema)
Iterator<ExtendedSchema>	AbstractSchemaRegistry.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>	AbstractSchemaRegistry.isCompatible(String subject, Schema newSchema, List<SchemaKey> previousSchemas, boolean normalize)
List<String>	SchemaRegistry.isCompatible(String subject, Schema newSchema, List<SchemaKey> previousSchemas, boolean normalize)
protected boolean	AbstractSchemaRegistry.isSubjectReferenced(String subject)	Whether any version of the subject is a reference target of another schema, counting soft- deleted versions and referrers since a soft delete can be restored.
protected boolean	AbstractSchemaRegistry.isSubjectVersionDeleted(String subject, int version)
protected KafkaStore<SchemaRegistryKey,SchemaRegistryValue>	KafkaSchemaRegistry.kafkaStore(SchemaRegistryConfig config)
List<String>	AbstractSchemaRegistry.listContexts()
List<String>	SchemaRegistry.listContexts()
List<ContextId>	AbstractSchemaRegistry.listIdsForGuid(String guid)
List<ContextId>	SchemaRegistry.listIdsForGuid(String guid)
Set<String>	AbstractSchemaRegistry.listSubjects(LookupFilter filter)
default Set<String>	SchemaRegistry.listSubjects()
Set<String>	SchemaRegistry.listSubjects(LookupFilter filter)
Set<String>	AbstractSchemaRegistry.listSubjectsForId(int id, String subject)
Set<String>	AbstractSchemaRegistry.listSubjectsForId(int id, String subject, boolean returnDeleted)
Set<String>	SchemaRegistry.listSubjectsForId(int id, String subject)
Set<String>	SchemaRegistry.listSubjectsForId(int id, String subject, boolean returnDeleted)
Set<String>	AbstractSchemaRegistry.listSubjectsWithPrefix(String prefix, LookupFilter filter)
Set<String>	SchemaRegistry.listSubjectsWithPrefix(String prefix, LookupFilter filter)
List<SubjectVersion>	AbstractSchemaRegistry.listVersionsForId(int id, String subject)
List<SubjectVersion>	AbstractSchemaRegistry.listVersionsForId(int id, String subject, boolean lookupDeleted)
List<SubjectVersion>	SchemaRegistry.listVersionsForId(int id, String subject, boolean lookupDeleted)
protected Schema	AbstractSchemaRegistry.lookUpSchemaUnderSubject(Config config, String subject, Schema schema, boolean normalize, boolean lookupDeletedSchema, boolean lookupLatestOnly)
Schema	AbstractSchemaRegistry.lookUpSchemaUnderSubject(String subject, Schema schema, boolean normalize, boolean lookupDeletedSchema)	Checks if given schema was ever registered under a subject.
default Schema	SchemaRegistry.lookUpSchemaUnderSubject(String subject, Schema schema, boolean lookupDeletedSchema)
Schema	SchemaRegistry.lookUpSchemaUnderSubject(String subject, Schema schema, boolean normalize, boolean lookupDeletedSchema)
Schema	AbstractSchemaRegistry.lookUpSchemaUnderSubjectUsingContexts(String subject, Schema schema, boolean normalize, boolean lookupDeletedSchema)
Schema	SchemaRegistry.lookUpSchemaUnderSubjectUsingContexts(String subject, Schema schema, boolean normalize, boolean lookupDeletedSchema)
protected boolean	AbstractSchemaRegistry.maybePopulateFromPrevious(Config config, Schema schema, List<ParsedSchemaHolder> undeletedVersions, int newVersion, boolean propagateSchemaTags)
Schema	AbstractSchemaRegistry.modifySchemaTags(String subject, Schema schema, TagSchemaRequest request)
Schema	KafkaSchemaRegistry.modifySchemaTagsOrForward(String subject, Schema schema, TagSchemaRequest request, Map<String,String> headerProperties)
default Schema	SchemaRegistry.modifySchemaTagsOrForward(String subject, Schema schema, TagSchemaRequest request, Map<String,String> headerProperties)
default AssociationBatchResponse	SchemaRegistry.mutateAssociations(String context, boolean dryRun, AssociationBatchRequest request)
AssociationBatchResponse	KafkaSchemaRegistry.mutateAssociationsOrForward(String context, boolean dryRun, AssociationBatchRequest request, Map<String,String> headerProperties)
default AssociationBatchResponse	SchemaRegistry.mutateAssociationsOrForward(String context, boolean dryRun, AssociationBatchRequest request, Map<String,String> headerProperties)
void	KafkaSchemaRegistry.postInit()
void	SchemaRegistry.postInit()
protected void	AbstractSchemaRegistry.putAssociation(AssociationValue associationValue)
protected void	KafkaSchemaRegistry.putAssociation(AssociationValue associationValue)
Schema	AbstractSchemaRegistry.register(String subject, RegisterSchemaRequest request, boolean normalize)
Schema	AbstractSchemaRegistry.register(String subject, RegisterSchemaRequest request, boolean normalize, boolean force)
Schema	KafkaSchemaRegistry.register(String subject, Schema schema, boolean normalize, boolean force, boolean propagateSchemaTags)	Register the given schema under the given subject.
default Schema	SchemaRegistry.register(String subject, RegisterSchemaRequest request, boolean normalize)	Registers what a request asks for, rather than a schema already extracted from it.
default Schema	SchemaRegistry.register(String subject, Schema schema)
default Schema	SchemaRegistry.register(String subject, Schema schema, boolean normalize)
default Schema	SchemaRegistry.register(String subject, Schema schema, boolean normalize, boolean propagateSchemaTags)
Schema	SchemaRegistry.register(String subject, Schema schema, boolean normalize, boolean force, boolean propagateSchemaTags)
Schema	KafkaSchemaRegistry.registerOrForward(String subject, RegisterSchemaRequest request, boolean normalize, boolean force, Map<String,String> headerProperties)
default Schema	SchemaRegistry.registerOrForward(String subject, RegisterSchemaRequest request, boolean normalize, boolean force, Map<String,String> headerProperties)
default Schema	SchemaRegistry.registerOrForward(String subject, RegisterSchemaRequest request, boolean normalize, Map<String,String> headerProperties)
SchemaValue	LazyParsedSchemaHolder.schemaValue()
SchemaValue	SchemaValueHolder.schemaValue()	Returns the schema value.
boolean	AbstractSchemaRegistry.schemaVersionExists(String subject, VersionId versionId, boolean returnDeletedSchema)
boolean	SchemaRegistry.schemaVersionExists(String subject, VersionId versionId, boolean returnDeletedSchema)
void	AbstractSchemaRegistry.setMode(String subject, ModeUpdateRequest mode)
void	KafkaSchemaRegistry.setMode(String subject, ModeUpdateRequest request, boolean force)
void	SchemaRegistry.setMode(String subject, ModeUpdateRequest mode)
void	SchemaRegistry.setMode(String subject, ModeUpdateRequest request, boolean force)
void	KafkaSchemaRegistry.setModeOrForward(String subject, ModeUpdateRequest mode, boolean force, Map<String,String> headerProperties)
default void	SchemaRegistry.setModeOrForward(String subject, ModeUpdateRequest mode, boolean force, Map<String,String> headerProperties)
protected Schema	AbstractSchemaRegistry.toSchemaWithTags(String subject, RegisterSchemaRequest request)	Converts a request to the schema it asks to be registered, applying any schema tags that the request adds or removes.
protected Schema	AbstractSchemaRegistry.validateDeleteSchemaVersion(String subject, int version, boolean permanentDelete)
protected void	AbstractSchemaRegistry.validateReferencesNotStronglyAssociated(String subject, Schema schema)	A schema reference and a STRONG (topic-owned) association are mutually exclusive: a subject claimed by its topic cannot be a reference target.

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

Modifier	Constructor	Description
protected	AbstractSchemaRegistry(SchemaRegistryConfig config, MetricsContainer metricsContainer)	Constructs an AbstractSchemaRegistry with the given configuration.
	KafkaSchemaRegistry(SchemaRegistryConfig config, Serializer<SchemaRegistryKey,SchemaRegistryValue> serializer)
	KafkaStore(SchemaRegistryConfig config, StoreUpdateHandler<K,V> storeUpdateHandler, Serializer<K,V> serializer, Store<K,V> localStore, K noopKey)