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	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	SubjectNotSoftDeletedException
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)
void	AbstractSchemaRegistry.checkIfSchemaWithIdExist(int id, Schema schema)
AssociationResponse	KafkaSchemaRegistry.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	KafkaSchemaRegistry.createOrUpdateAssociation(String context, boolean dryRun, AssociationCreateOrUpdateRequest request)
AssociationResponse	KafkaSchemaRegistry.createOrUpdateAssociation(String context, boolean dryRun, AssociationCreateOrUpdateRequest request, boolean isCreateOnly)
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)
void	KafkaSchemaRegistry.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)
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)
default void	SchemaRegistry.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)
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	KafkaSchemaRegistry.getAssociationByGuid(String guid)
default Association	SchemaRegistry.getAssociationByGuid(String guid)
List<Association>	KafkaSchemaRegistry.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>	KafkaSchemaRegistry.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>	KafkaSchemaRegistry.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)
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.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)
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()
Schema	AbstractSchemaRegistry.register(String subject, RegisterSchemaRequest request, boolean normalize)
Schema	KafkaSchemaRegistry.register(String subject, Schema schema, boolean normalize, boolean propagateSchemaTags)	Register the given schema under the given subject.
default Schema	SchemaRegistry.register(String subject, Schema schema)
default Schema	SchemaRegistry.register(String subject, Schema schema, boolean normalize)
Schema	SchemaRegistry.register(String subject, Schema schema, boolean normalize, boolean propagateSchemaTags)
Schema	KafkaSchemaRegistry.registerOrForward(String subject, RegisterSchemaRequest request, boolean normalize, 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)

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)