Package io.confluent.kafka.schemaregistry.storage

Class AbstractSchemaRegistry

java.lang.Object

io.confluent.kafka.schemaregistry.storage.AbstractSchemaRegistry

All Implemented Interfaces:

SchemaVersionFetcher, SslFactory.SslFactoryCreated, SchemaRegistry

Direct Known Subclasses:

KafkaSchemaRegistry

public abstract class AbstractSchemaRegistry
extends Object
implements SchemaRegistry, SslFactory.SslFactoryCreated

Abstract base class for SchemaRegistry implementations that provides common state management and shared functionality.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	AbstractSchemaRegistry.RawSchema	Internal class representing a raw schema with parsing options.
static class	AbstractSchemaRegistry.SchemeAndPort

Field Summary

Fields

Modifier and Type	Field	Description
protected final boolean	allowModeChanges
protected final SchemaRegistryConfig	config
protected final int	contextSearchDefaultLimit
protected final int	contextSearchMaxLimit
protected final List<org.eclipse.jetty.server.Handler.Singleton>	customHandler
protected final CompatibilityLevel	defaultCompatibilityLevel
protected final Mode	defaultMode
protected final boolean	defaultValidateFields
protected final boolean	defaultValidateNewSchemas
protected final AtomicBoolean	initialized
protected LookupCache<SchemaRegistryKey,SchemaRegistryValue>	lookupCache
protected MetadataEncoderService	metadataEncoder
protected final MetricsContainer	metricsContainer
protected final com.github.benmanes.caffeine.cache.LoadingCache<AbstractSchemaRegistry.RawSchema,ParsedSchema>	newSchemaCache
protected static final Lock	NO_OP_LOCK
protected final com.github.benmanes.caffeine.cache.LoadingCache<AbstractSchemaRegistry.RawSchema,ParsedSchema>	oldSchemaCache
protected final Map<String,Object>	props
protected final Map<String,SchemaProvider>	providers
protected final List<SchemaRegistryResourceExtension>	resourceExtensions
protected RuleSetHandler	ruleSetHandler
protected final int	schemaSearchDefaultLimit
protected final int	schemaSearchMaxLimit
protected final SslFactory	sslFactory
protected Store<SchemaRegistryKey,SchemaRegistryValue>	store
protected final int	subjectSearchDefaultLimit
protected final int	subjectSearchMaxLimit
protected final int	subjectVersionSearchDefaultLimit
protected final int	subjectVersionSearchMaxLimit
protected final org.apache.kafka.common.utils.Time	time
protected final List<UpdateRequestHandler>	updateRequestHandlers

Fields inherited from interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry

DEFAULT_TENANT, FIELD_CONFLICTS_WITH_RESERVED_FIELD, MAX_VERSION, MIN_VERSION, RESERVED_FIELD_REMOVED, RESOURCE_WILDCARD

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractSchemaRegistry(SchemaRegistryConfig config, MetricsContainer metricsContainer)	Constructs an AbstractSchemaRegistry with the given configuration.

Method Summary

Modifier and Type	Method	Description
void	addCustomHandler(org.eclipse.jetty.server.Handler.Singleton handler)
void	addUpdateRequestHandler(UpdateRequestHandler updateRequestHandler)
protected CloseableIterator<SchemaRegistryValue>	allContexts()
boolean	allowEmptySubject()	Whether the current registration context allows an empty-string subject name
Iterator<ExtendedSchema>	allVersionsIncludingAliasesWithSubjectPrefix(String prefix, LookupFilter filter, boolean returnLatestOnly, Predicate<Schema> postFilter)
AssociationBatchResponse	batchGetAssociations(boolean includeSchemas, AssociationBatchGetRequest request)
protected ParsedSchema	canonicalizeSchema(Schema schema, Config config, boolean isNew, boolean normalize)
protected void	checkDeleteAssociation(Association oldAssociation, boolean cascadeLifecycle)
void	checkIfSchemaWithIdExist(int id, Schema schema)
protected void	checkRegisterMode(String subject, Schema schema)
void	clearNewSchemaCache()
void	clearOldSchemaCache()
SchemaRegistryConfig	config()
AssociationResponse	createAssociation(String context, boolean dryRun, AssociationCreateOrUpdateRequest request)
AssociationResponse	createOrUpdateAssociation(String context, boolean dryRun, AssociationCreateOrUpdateRequest request)
AssociationResponse	createOrUpdateAssociation(String context, boolean dryRun, AssociationCreateOrUpdateRequest request, boolean isCreate)
protected void	deleteAssociationEntry(Association oldAssociation)
void	deleteAssociations(String resourceId, String resourceType, List<String> associationTypes, boolean cascadeLifecycle, boolean dryRun)
void	extractSchemaTags(Schema schema, List<String> tags)
SchemaString	get(int id, String subject)
Schema	get(String subject, int version, boolean returnDeletedSchema)
protected List<SchemaKey>	getAllSchemaKeysDescending(String subject)
Iterator<SchemaKey>	getAllVersions(String subject, LookupFilter filter)
Association	getAssociationByGuid(String guid)
List<Association>	getAssociationsByResourceId(String resourceId, String resourceType, List<String> associationTypes, LifecyclePolicy lifecycle)
List<Association>	getAssociationsByResourceName(String resourceName, String resourceNamespace, String resourceType, List<String> associationTypes, LifecyclePolicy lifecycle)
List<Association>	getAssociationsByResourceNamespace(String resourceNamespace, String resourceType, List<String> associationTypes, LifecyclePolicy lifecycle)
List<Association>	getAssociationsBySubject(String subject, String resourceType, List<String> associationTypes, LifecyclePolicy lifecycle)
SchemaString	getByGuid(String guid, String format)
UpdateRequestHandler	getCompositeUpdateRequestHandler()
Config	getConfig(String subject)
Config	getConfigInScope(String subject)
List<org.eclipse.jetty.server.Handler.Singleton>	getCustomHandler()
HostnameVerifier	getHostnameVerifier()
static io.confluent.rest.NamedURI	getInterInstanceListener(List<io.confluent.rest.NamedURI> listeners, String interInstanceListenerName, String requestedScheme)	This method returns a listener to be used for inter-instance communication.
Schema	getLatestVersion(String subject)
Schema	getLatestWithMetadata(String subject, Map<String,String> metadata, boolean lookupDeletedSchema)
LookupCache<SchemaRegistryKey,SchemaRegistryValue>	getLookupCache()
MetadataEncoderService	getMetadataEncoder()	Returns the metadata encoder, or null if SR-level encoding is disabled.
MetricsContainer	getMetricsContainer()
Mode	getMode(String subject)
Mode	getModeInScope(String subject)
protected Set<ContextId>	getReferencedBy(SchemaKey key, boolean lookupDeletedSchema)
List<ContextId>	getReferencedBy(String subject, VersionId versionId, boolean lookupDeletedSchema)
protected Set<String>	getReferencedBySubjects(SchemaKey key, boolean lookupDeletedSchema)	Returns the set of subjects that have at least one schema version referencing the given key.
List<SchemaRegistryResourceExtension>	getResourceExtensions()
RuleSetHandler	getRuleSetHandler()
SchemaValue	getSchemaValue(SchemaKey key)
SslFactory	getSslFactory()
Schema	getUsingContexts(String subject, int version, boolean returnDeletedSchema)
Iterator<ExtendedSchema>	getVersionsWithSubjectPrefix(String prefix, boolean includeAliases, LookupFilter filter, boolean returnLatestOnly, Predicate<Schema> postFilter)
boolean	hasSubjects(String subject, boolean lookupDeletedSubjects)
protected Map<String,SchemaProvider>	initProviders()
protected List<SchemaRegistryResourceExtension>	initResourceExtensions()
void	invalidateFromNewSchemaCache(Schema schemaKey)
protected void	invalidateFromOldSchemaCache(Schema schemaKey)
List<String>	isCompatible(String subject, Schema newSchema, List<SchemaKey> previousSchemas, boolean normalize)
protected List<String>	isCompatibleWithPrevious(Config config, ParsedSchema parsedSchema, List<ParsedSchemaHolder> previousSchemas)
protected boolean	isReadOnlyMode(String subject)
protected boolean	isSchemaFieldValidationEnabled(Config config)
protected boolean	isSchemaNewSchemaValidationEnabled(Config config)
protected boolean	isSubjectVersionDeleted(String subject, int version)
protected CloseableIterator<SchemaRegistryValue>	listAssociationValuesByResourceName(String resourceName, String resourceNamespace, String resourceType)
protected CloseableIterator<SchemaRegistryValue>	listAssociationValuesByResourceNamespace(String resourceNamespace, String resourceType)
List<String>	listContexts()
List<ContextId>	listIdsForGuid(String guid)
Set<String>	listSubjects(LookupFilter filter)
Set<String>	listSubjectsForId(int id, String subject)
Set<String>	listSubjectsForId(int id, String subject, boolean returnDeleted)
Set<String>	listSubjectsWithPrefix(String prefix, LookupFilter filter)
List<SubjectVersion>	listVersionsForId(int id, String subject)
List<SubjectVersion>	listVersionsForId(int id, String subject, boolean lookupDeleted)
protected ParsedSchema	loadSchema(Schema schema, boolean isNew, boolean normalize)	Loads a schema from the cache or parses it if not cached.
protected Lock	lockForAssociation(String context)
protected void	logSchemaOp(Schema schema, String operation)
protected Schema	lookUpSchemaUnderSubject(Config config, String subject, Schema schema, boolean normalize, boolean lookupDeletedSchema, boolean lookupLatestOnly)
Schema	lookUpSchemaUnderSubject(String subject, Schema schema, boolean normalize, boolean lookupDeletedSchema)	Checks if given schema was ever registered under a subject.
Schema	lookUpSchemaUnderSubjectUsingContexts(String subject, Schema schema, boolean normalize, boolean lookupDeletedSchema)
protected boolean	maybePopulateFromPrevious(Config config, Schema schema, List<ParsedSchemaHolder> undeletedVersions, int newVersion, boolean propagateSchemaTags)
protected boolean	maybeSetMetadataRuleSet(Config config, Schema schema, Schema previousSchema, Integer newVersion)
protected ParsedSchema	maybeValidateAndNormalizeSchema(ParsedSchema parsedSchema, Schema schema, Config config, boolean normalize)
Schema	modifySchemaTags(String subject, Schema schema, TagSchemaRequest request)
AssociationBatchResponse	mutateAssociations(String context, boolean dryRun, AssociationBatchRequest request)
int	normalizeContextLimit(int suppliedLimit)
int	normalizeLimit(int suppliedLimit, int defaultLimit, int maxLimit)
int	normalizeSchemaLimit(int suppliedLimit)
int	normalizeSubjectLimit(int suppliedLimit)
int	normalizeSubjectVersionLimit(int suppliedLimit)
void	onKeystoreCreated(KeyStore keystore)
void	onTruststoreCreated(KeyStore truststore)
ParsedSchema	parseSchema(Schema schema)
ParsedSchema	parseSchema(Schema schema, boolean isNew, boolean normalize)
Map<String,Object>	properties()
protected void	putAssociation(AssociationValue associationValue)
Schema	register(String subject, RegisterSchemaRequest request, boolean normalize)
protected void	registerProviders(Map<String,SchemaProvider> providerMap, List<SchemaProvider> schemaProviders)
void	removeCustomHandler(org.eclipse.jetty.server.Handler.Singleton handler)
protected QualifiedSubject	replaceAlias(String context, String subject)
SchemaProvider	schemaProvider(String schemaType)
Set<String>	schemaTypes()
boolean	schemaVersionExists(String subject, VersionId versionId, boolean returnDeletedSchema)
void	setMode(String subject, ModeUpdateRequest mode)
void	setRuleSetHandler(RuleSetHandler ruleSetHandler)
Set<String>	subjects(String subject, boolean lookupDeletedSubjects)
protected void	syncBeforeAssociationWrite(String qualifiedSubject)
Schema	toSchemaEntity(SchemaValue schemaValue)
protected Schema	validateDeleteSchemaVersion(String subject, int version, boolean permanentDelete)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.confluent.kafka.schemaregistry.storage.SchemaRegistry

addLeaderChangeListener, close, createAssociationOrForward, createOrUpdateAssociationOrForward, deleteAssociations, deleteAssociationsOrForward, deleteConfigOrForward, deleteContext, deleteContextOrForward, deleteSchemaVersion, deleteSchemaVersionOrForward, deleteSubject, deleteSubjectConfig, deleteSubjectMode, deleteSubjectMode, deleteSubjectModeOrForward, deleteSubjectOrForward, get, getByVersion, getGroupId, getKafkaClusterId, getKafkaStore, healthy, init, initialized, isLeader, leaderIdentity, leaderRestService, listSubjects, lookUpSchemaUnderSubject, modifySchemaTagsOrForward, mutateAssociationsOrForward, myIdentity, postInit, register, register, register, registerOrForward, setLeader, setMode, setModeOrForward, setTenant, tenant, updateConfig, updateConfigOrForward

Field Details

NO_OP_LOCK

protected static final Lock NO_OP_LOCK

store

protected Store<SchemaRegistryKey,SchemaRegistryValue> store

config

protected final SchemaRegistryConfig config

props

protected final Map<String,Object> props

metricsContainer

protected final MetricsContainer metricsContainer

providers

protected final Map<String,SchemaProvider> providers

resourceExtensions

protected final List<SchemaRegistryResourceExtension> resourceExtensions

customHandler

protected final List<org.eclipse.jetty.server.Handler.Singleton> customHandler

updateRequestHandlers

protected final List<UpdateRequestHandler> updateRequestHandlers

sslFactory

protected final SslFactory sslFactory

newSchemaCache

protected final com.github.benmanes.caffeine.cache.LoadingCache<AbstractSchemaRegistry.RawSchema,ParsedSchema> newSchemaCache

oldSchemaCache

protected final com.github.benmanes.caffeine.cache.LoadingCache<AbstractSchemaRegistry.RawSchema,ParsedSchema> oldSchemaCache

defaultCompatibilityLevel

protected final CompatibilityLevel defaultCompatibilityLevel

defaultValidateFields

protected final boolean defaultValidateFields

defaultValidateNewSchemas

protected final boolean defaultValidateNewSchemas

defaultMode

protected final Mode defaultMode

schemaSearchDefaultLimit

protected final int schemaSearchDefaultLimit

schemaSearchMaxLimit

protected final int schemaSearchMaxLimit

subjectVersionSearchDefaultLimit

protected final int subjectVersionSearchDefaultLimit

subjectVersionSearchMaxLimit

protected final int subjectVersionSearchMaxLimit

subjectSearchDefaultLimit

protected final int subjectSearchDefaultLimit

contextSearchMaxLimit

protected final int contextSearchMaxLimit

contextSearchDefaultLimit

protected final int contextSearchDefaultLimit

subjectSearchMaxLimit

protected final int subjectSearchMaxLimit

allowModeChanges

protected final boolean allowModeChanges

initialized

protected final AtomicBoolean initialized

time

protected final org.apache.kafka.common.utils.Time time

lookupCache

protected LookupCache<SchemaRegistryKey,SchemaRegistryValue> lookupCache

metadataEncoder

protected MetadataEncoderService metadataEncoder

ruleSetHandler

protected RuleSetHandler ruleSetHandler

Constructor Details

AbstractSchemaRegistry

protected AbstractSchemaRegistry(SchemaRegistryConfig config,
 MetricsContainer metricsContainer)
                          throws SchemaRegistryException

Constructs an AbstractSchemaRegistry with the given configuration.

Parameters:

config - the schema registry configuration

metricsContainer - the metrics container for tracking metrics

Throws:

SchemaRegistryException

Method Details

initResourceExtensions

protected List<SchemaRegistryResourceExtension> initResourceExtensions()

getInterInstanceListener

public static io.confluent.rest.NamedURI getInterInstanceListener(List<io.confluent.rest.NamedURI> listeners,
 String interInstanceListenerName,
 String requestedScheme)
                                                           throws SchemaRegistryException

This method returns a listener to be used for inter-instance communication. It iterates through the list of listeners until it finds one whose name matches the inter.instance.listener.name config. If no such listener is found, it returns the last listener matching the requested scheme.

When there is no matching named listener, in theory, any port from any listener would be sufficient. Choosing the last, instead of say the first, is arbitrary. The port used by this listener also forms the identity of the schema registry instance along with the host name.

Throws:

SchemaRegistryException

initProviders

protected Map<String,SchemaProvider> initProviders()

registerProviders

protected void registerProviders(Map<String,SchemaProvider> providerMap,
 List<SchemaProvider> schemaProviders)

loadSchema

protected ParsedSchema loadSchema(Schema schema,
 boolean isNew,
 boolean normalize)
                           throws InvalidSchemaException

Loads a schema from the cache or parses it if not cached.

Throws:

InvalidSchemaException

register

public Schema register(String subject,
 RegisterSchemaRequest request,
 boolean normalize)
                throws SchemaRegistryException

Throws:

SchemaRegistryException

isReadOnlyMode

protected boolean isReadOnlyMode(String subject)
                          throws SchemaRegistryStoreException

Throws:

SchemaRegistryStoreException

checkRegisterMode

protected void checkRegisterMode(String subject,
 Schema schema)
                          throws OperationNotPermittedException,
SchemaRegistryStoreException

Throws:

OperationNotPermittedException

SchemaRegistryStoreException

maybeSetMetadataRuleSet

protected boolean maybeSetMetadataRuleSet(Config config,
 Schema schema,
 Schema previousSchema,
 Integer newVersion)

maybePopulateFromPrevious

protected boolean maybePopulateFromPrevious(Config config,
 Schema schema,
 List<ParsedSchemaHolder> undeletedVersions,
 int newVersion,
 boolean propagateSchemaTags)
                                     throws SchemaRegistryException

Throws:

SchemaRegistryException

modifySchemaTags

public Schema modifySchemaTags(String subject,
 Schema schema,
 TagSchemaRequest request)
                        throws SchemaRegistryException

Throws:

SchemaRegistryException

logSchemaOp

protected void logSchemaOp(Schema schema,
 String operation)

isSchemaFieldValidationEnabled

protected boolean isSchemaFieldValidationEnabled(Config config)

isSchemaNewSchemaValidationEnabled

protected boolean isSchemaNewSchemaValidationEnabled(Config config)

maybeValidateAndNormalizeSchema

protected ParsedSchema maybeValidateAndNormalizeSchema(ParsedSchema parsedSchema,
 Schema schema,
 Config config,
 boolean normalize)
                                                throws InvalidSchemaException

Throws:

InvalidSchemaException

canonicalizeSchema

protected ParsedSchema canonicalizeSchema(Schema schema,
 Config config,
 boolean isNew,
 boolean normalize)
                                   throws InvalidSchemaException

Throws:

InvalidSchemaException

isSubjectVersionDeleted

protected boolean isSubjectVersionDeleted(String subject,
 int version)
                                   throws SchemaRegistryException

Throws:

SchemaRegistryException

validateDeleteSchemaVersion

protected Schema validateDeleteSchemaVersion(String subject,
 int version,
 boolean permanentDelete)
                                      throws SchemaRegistryException

Throws:

SchemaRegistryException

getAllSchemaKeysDescending

protected List<SchemaKey> getAllSchemaKeysDescending(String subject)
                                              throws SchemaRegistryException

Throws:

SchemaRegistryException

lookUpSchemaUnderSubject

protected Schema lookUpSchemaUnderSubject(Config config,
 String subject,
 Schema schema,
 boolean normalize,
 boolean lookupDeletedSchema,
 boolean lookupLatestOnly)
                                   throws SchemaRegistryException

Throws:

SchemaRegistryException

lookUpSchemaUnderSubject

public Schema lookUpSchemaUnderSubject(String subject,
 Schema schema,
 boolean normalize,
 boolean lookupDeletedSchema)
                                throws SchemaRegistryException

Checks if given schema was ever registered under a subject. If found, it returns the version of the schema under the subject. If not, returns -1

Specified by:

lookUpSchemaUnderSubject in interface SchemaRegistry

Throws:

SchemaRegistryException

checkIfSchemaWithIdExist

public void checkIfSchemaWithIdExist(int id,
 Schema schema)
                              throws SchemaRegistryException,
StoreException

Throws:

SchemaRegistryException

StoreException

allContexts

protected CloseableIterator<SchemaRegistryValue> allContexts()
                                                      throws SchemaRegistryException

Throws:

SchemaRegistryException

listVersionsForId

public List<SubjectVersion> listVersionsForId(int id,
 String subject)
                                       throws SchemaRegistryException

Throws:

SchemaRegistryException

listVersionsForId

public List<SubjectVersion> listVersionsForId(int id,
 String subject,
 boolean lookupDeleted)
                                       throws SchemaRegistryException

Specified by:

listVersionsForId in interface SchemaRegistry

Throws:

SchemaRegistryException

allVersionsIncludingAliasesWithSubjectPrefix

public Iterator<ExtendedSchema> allVersionsIncludingAliasesWithSubjectPrefix(String prefix,
 LookupFilter filter,
 boolean returnLatestOnly,
 Predicate<Schema> postFilter)
                                                                      throws SchemaRegistryException

Throws:

SchemaRegistryException

isCompatibleWithPrevious

protected List<String> isCompatibleWithPrevious(Config config,
 ParsedSchema parsedSchema,
 List<ParsedSchemaHolder> previousSchemas)

removeCustomHandler

public void removeCustomHandler(org.eclipse.jetty.server.Handler.Singleton handler)

normalizeLimit

public int normalizeLimit(int suppliedLimit,
 int defaultLimit,
 int maxLimit)

clearNewSchemaCache

public void clearNewSchemaCache()

Specified by:

clearNewSchemaCache in interface SchemaRegistry

clearOldSchemaCache

public void clearOldSchemaCache()

Specified by:

clearOldSchemaCache in interface SchemaRegistry

invalidateFromNewSchemaCache

public void invalidateFromNewSchemaCache(Schema schemaKey)

Specified by:

invalidateFromNewSchemaCache in interface SchemaRegistry

invalidateFromOldSchemaCache

protected void invalidateFromOldSchemaCache(Schema schemaKey)

normalizeSchemaLimit

public int normalizeSchemaLimit(int suppliedLimit)

Specified by:

normalizeSchemaLimit in interface SchemaRegistry

normalizeSubjectLimit

public int normalizeSubjectLimit(int suppliedLimit)

Specified by:

normalizeSubjectLimit in interface SchemaRegistry

normalizeContextLimit

public int normalizeContextLimit(int suppliedLimit)

Specified by:

normalizeContextLimit in interface SchemaRegistry

normalizeSubjectVersionLimit

public int normalizeSubjectVersionLimit(int suppliedLimit)

Specified by:

normalizeSubjectVersionLimit in interface SchemaRegistry

getHostnameVerifier

public HostnameVerifier getHostnameVerifier()
                                     throws SchemaRegistryStoreException

Specified by:

getHostnameVerifier in interface SchemaRegistry

Throws:

SchemaRegistryStoreException

get

public SchemaString get(int id,
 String subject)
                 throws SchemaRegistryException

Specified by:

get in interface SchemaRegistry

Throws:

SchemaRegistryException

get

public Schema get(String subject,
 int version,
 boolean returnDeletedSchema)
           throws SchemaRegistryException

Specified by:

get in interface SchemaRegistry

Throws:

SchemaRegistryException

setMode

public void setMode(String subject,
 ModeUpdateRequest mode)
             throws SchemaRegistryException

Specified by:

setMode in interface SchemaRegistry

Throws:

SchemaRegistryException

getModeInScope

public Mode getModeInScope(String subject)
                    throws SchemaRegistryStoreException

Specified by:

getModeInScope in interface SchemaRegistry

Throws:

SchemaRegistryStoreException

getMode

public Mode getMode(String subject)
             throws SchemaRegistryStoreException

Specified by:

getMode in interface SchemaRegistry

Throws:

SchemaRegistryStoreException

isCompatible

public List<String> isCompatible(String subject,
 Schema newSchema,
 List<SchemaKey> previousSchemas,
 boolean normalize)
                          throws SchemaRegistryException

Specified by:

isCompatible in interface SchemaRegistry

Parameters:

previousSchemas - Full schema history in chronological order

Throws:

SchemaRegistryException

getConfigInScope

public Config getConfigInScope(String subject)
                        throws SchemaRegistryStoreException

Specified by:

getConfigInScope in interface SchemaRegistry

Throws:

SchemaRegistryStoreException

replaceAlias

protected QualifiedSubject replaceAlias(String context,
 String subject)

getConfig

public Config getConfig(String subject)
                 throws SchemaRegistryStoreException

Specified by:

getConfig in interface SchemaRegistry

Throws:

SchemaRegistryStoreException

getLatestVersion

public Schema getLatestVersion(String subject)
                        throws SchemaRegistryException

Specified by:

getLatestVersion in interface SchemaRegistry

Throws:

SchemaRegistryException

getVersionsWithSubjectPrefix

public Iterator<ExtendedSchema> getVersionsWithSubjectPrefix(String prefix,
 boolean includeAliases,
 LookupFilter filter,
 boolean returnLatestOnly,
 Predicate<Schema> postFilter)
                                                      throws SchemaRegistryException

Specified by:

getVersionsWithSubjectPrefix in interface SchemaRegistry

Throws:

SchemaRegistryException

getAllVersions

public Iterator<SchemaKey> getAllVersions(String subject,
 LookupFilter filter)
                                   throws SchemaRegistryException

Specified by:

getAllVersions in interface SchemaRegistry

Throws:

SchemaRegistryException

hasSubjects

public boolean hasSubjects(String subject,
 boolean lookupDeletedSubjects)
                    throws SchemaRegistryStoreException

Specified by:

hasSubjects in interface SchemaRegistry

Throws:

SchemaRegistryStoreException

subjects

public Set<String> subjects(String subject,
 boolean lookupDeletedSubjects)
                     throws SchemaRegistryStoreException

Specified by:

subjects in interface SchemaRegistry

Throws:

SchemaRegistryStoreException

listSubjectsForId

public Set<String> listSubjectsForId(int id,
 String subject,
 boolean returnDeleted)
                              throws SchemaRegistryException

Specified by:

listSubjectsForId in interface SchemaRegistry

Throws:

SchemaRegistryException

listSubjectsForId

public Set<String> listSubjectsForId(int id,
 String subject)
                              throws SchemaRegistryException

Specified by:

listSubjectsForId in interface SchemaRegistry

Throws:

SchemaRegistryException

listContexts

public List<String> listContexts()
                          throws SchemaRegistryException

Specified by:

listContexts in interface SchemaRegistry

Throws:

SchemaRegistryException

listSubjectsWithPrefix

public Set<String> listSubjectsWithPrefix(String prefix,
 LookupFilter filter)
                                   throws SchemaRegistryException

Specified by:

listSubjectsWithPrefix in interface SchemaRegistry

Throws:

SchemaRegistryException

listSubjects

public Set<String> listSubjects(LookupFilter filter)
                         throws SchemaRegistryException

Specified by:

listSubjects in interface SchemaRegistry

Throws:

SchemaRegistryException

getReferencedBy

public List<ContextId> getReferencedBy(String subject,
 VersionId versionId,
 boolean lookupDeletedSchema)
                                throws SchemaRegistryException

Specified by:

getReferencedBy in interface SchemaRegistry

Throws:

SchemaRegistryException

getReferencedBy

protected Set<ContextId> getReferencedBy(SchemaKey key,
 boolean lookupDeletedSchema)
                                  throws StoreException,
SchemaRegistryException

Throws:

StoreException

SchemaRegistryException

getReferencedBySubjects

protected Set<String> getReferencedBySubjects(SchemaKey key,
 boolean lookupDeletedSchema)
                                       throws StoreException,
SchemaRegistryException

Returns the set of subjects that have at least one schema version referencing the given key. When lookupDeletedSchema is false, references from soft-deleted schema versions are excluded.

Throws:

StoreException

SchemaRegistryException

listIdsForGuid

public List<ContextId> listIdsForGuid(String guid)
                               throws SchemaRegistryException

Specified by:

listIdsForGuid in interface SchemaRegistry

Throws:

SchemaRegistryException

getByGuid

public SchemaString getByGuid(String guid,
 String format)
                       throws SchemaRegistryException

Specified by:

getByGuid in interface SchemaRegistry

Throws:

SchemaRegistryException

getSchemaValue

public SchemaValue getSchemaValue(SchemaKey key)
                           throws SchemaRegistryException

Specified by:

getSchemaValue in interface SchemaRegistry

Throws:

SchemaRegistryException

toSchemaEntity

public Schema toSchemaEntity(SchemaValue schemaValue)
                      throws SchemaRegistryStoreException

Specified by:

toSchemaEntity in interface SchemaRegistry

Throws:

SchemaRegistryStoreException

schemaVersionExists

public boolean schemaVersionExists(String subject,
 VersionId versionId,
 boolean returnDeletedSchema)
                            throws SchemaRegistryException

Specified by:

schemaVersionExists in interface SchemaRegistry

Throws:

SchemaRegistryException

getUsingContexts

public Schema getUsingContexts(String subject,
 int version,
 boolean returnDeletedSchema)
                        throws SchemaRegistryException

Specified by:

getUsingContexts in interface SchemaRegistry

Throws:

SchemaRegistryException

parseSchema

public ParsedSchema parseSchema(Schema schema,
 boolean isNew,
 boolean normalize)
                         throws InvalidSchemaException

Specified by:

parseSchema in interface SchemaRegistry

Throws:

InvalidSchemaException

parseSchema

public ParsedSchema parseSchema(Schema schema)
                         throws InvalidSchemaException

Specified by:

parseSchema in interface SchemaRegistry

Throws:

InvalidSchemaException

extractSchemaTags

public void extractSchemaTags(Schema schema,
 List<String> tags)
                       throws SchemaRegistryException

Specified by:

extractSchemaTags in interface SchemaRegistry

Throws:

SchemaRegistryException

lookUpSchemaUnderSubjectUsingContexts

public Schema lookUpSchemaUnderSubjectUsingContexts(String subject,
 Schema schema,
 boolean normalize,
 boolean lookupDeletedSchema)
                                             throws SchemaRegistryException

Specified by:

lookUpSchemaUnderSubjectUsingContexts in interface SchemaRegistry

Throws:

SchemaRegistryException

getLatestWithMetadata

public Schema getLatestWithMetadata(String subject,
 Map<String,String> metadata,
 boolean lookupDeletedSchema)
                             throws SchemaRegistryException

Specified by:

getLatestWithMetadata in interface SchemaRegistry

Throws:

SchemaRegistryException

allowEmptySubject

public boolean allowEmptySubject()

Description copied from interface: SchemaRegistry

Whether the current registration context allows an empty-string subject name

Specified by:

allowEmptySubject in interface SchemaRegistry

getLookupCache

public LookupCache<SchemaRegistryKey,SchemaRegistryValue> getLookupCache()

Specified by:

getLookupCache in interface SchemaRegistry

schemaTypes

public Set<String> schemaTypes()

Specified by:

schemaTypes in interface SchemaRegistry

config

public SchemaRegistryConfig config()

Specified by:

config in interface SchemaRegistry

properties

public Map<String,Object> properties()

Specified by:

properties in interface SchemaRegistry

getMetadataEncoder

public MetadataEncoderService getMetadataEncoder()

Description copied from interface: SchemaRegistry

Returns the metadata encoder, or null if SR-level encoding is disabled.

Specified by:

getMetadataEncoder in interface SchemaRegistry

addUpdateRequestHandler

public void addUpdateRequestHandler(UpdateRequestHandler updateRequestHandler)

Specified by:

addUpdateRequestHandler in interface SchemaRegistry

getCompositeUpdateRequestHandler

public UpdateRequestHandler getCompositeUpdateRequestHandler()

Specified by:

getCompositeUpdateRequestHandler in interface SchemaRegistry

getCustomHandler

public List<org.eclipse.jetty.server.Handler.Singleton> getCustomHandler()

Specified by:

getCustomHandler in interface SchemaRegistry

addCustomHandler

public void addCustomHandler(org.eclipse.jetty.server.Handler.Singleton handler)

Specified by:

addCustomHandler in interface SchemaRegistry

getMetricsContainer

public MetricsContainer getMetricsContainer()

Specified by:

getMetricsContainer in interface SchemaRegistry

getResourceExtensions

public List<SchemaRegistryResourceExtension> getResourceExtensions()

Specified by:

getResourceExtensions in interface SchemaRegistry

schemaProvider

public SchemaProvider schemaProvider(String schemaType)

Specified by:

schemaProvider in interface SchemaRegistry

getRuleSetHandler

public RuleSetHandler getRuleSetHandler()

Specified by:

getRuleSetHandler in interface SchemaRegistry

setRuleSetHandler

public void setRuleSetHandler(RuleSetHandler ruleSetHandler)

Specified by:

setRuleSetHandler in interface SchemaRegistry

getSslFactory

public SslFactory getSslFactory()

Specified by:

getSslFactory in interface SchemaRegistry

onKeystoreCreated

public void onKeystoreCreated(KeyStore keystore)

Specified by:

onKeystoreCreated in interface SslFactory.SslFactoryCreated

onTruststoreCreated

public void onTruststoreCreated(KeyStore truststore)

Specified by:

onTruststoreCreated in interface SslFactory.SslFactoryCreated

syncBeforeAssociationWrite

protected void syncBeforeAssociationWrite(String qualifiedSubject)
                                   throws SchemaRegistryStoreException

Throws:

SchemaRegistryStoreException

putAssociation

protected void putAssociation(AssociationValue associationValue)
                       throws SchemaRegistryException

Throws:

SchemaRegistryException

deleteAssociationEntry

protected void deleteAssociationEntry(Association oldAssociation)
                               throws SchemaRegistryException

Throws:

SchemaRegistryException

lockForAssociation

protected Lock lockForAssociation(String context)

listAssociationValuesByResourceName

protected CloseableIterator<SchemaRegistryValue> listAssociationValuesByResourceName(String resourceName,
 String resourceNamespace,
 String resourceType)
                                                                              throws StoreException

Throws:

StoreException

listAssociationValuesByResourceNamespace

protected CloseableIterator<SchemaRegistryValue> listAssociationValuesByResourceNamespace(String resourceNamespace,
 String resourceType)
                                                                                   throws StoreException

Throws:

StoreException

createAssociation

public AssociationResponse createAssociation(String context,
 boolean dryRun,
 AssociationCreateOrUpdateRequest request)
                                      throws SchemaRegistryException

Specified by:

createAssociation in interface SchemaRegistry

Throws:

SchemaRegistryException

createOrUpdateAssociation

public AssociationResponse createOrUpdateAssociation(String context,
 boolean dryRun,
 AssociationCreateOrUpdateRequest request)
                                              throws SchemaRegistryException

Specified by:

createOrUpdateAssociation in interface SchemaRegistry

Throws:

SchemaRegistryException

createOrUpdateAssociation

public AssociationResponse createOrUpdateAssociation(String context,
 boolean dryRun,
 AssociationCreateOrUpdateRequest request,
 boolean isCreate)
                                              throws SchemaRegistryException

Throws:

SchemaRegistryException

checkDeleteAssociation

protected void checkDeleteAssociation(Association oldAssociation,
 boolean cascadeLifecycle)
                               throws SchemaRegistryException

Throws:

SchemaRegistryException

deleteAssociations

public void deleteAssociations(String resourceId,
 String resourceType,
 List<String> associationTypes,
 boolean cascadeLifecycle,
 boolean dryRun)
                        throws SchemaRegistryException

Throws:

SchemaRegistryException

batchGetAssociations

public AssociationBatchResponse batchGetAssociations(boolean includeSchemas,
 AssociationBatchGetRequest request)
                                              throws SchemaRegistryException

Specified by:

batchGetAssociations in interface SchemaRegistry

Throws:

SchemaRegistryException

mutateAssociations

public AssociationBatchResponse mutateAssociations(String context,
 boolean dryRun,
 AssociationBatchRequest request)

Specified by:

mutateAssociations in interface SchemaRegistry

getAssociationByGuid

public Association getAssociationByGuid(String guid)
                                 throws SchemaRegistryException

Specified by:

getAssociationByGuid in interface SchemaRegistry

Throws:

SchemaRegistryException

getAssociationsBySubject

public List<Association> getAssociationsBySubject(String subject,
 String resourceType,
 List<String> associationTypes,
 LifecyclePolicy lifecycle)
                                           throws SchemaRegistryException

Specified by:

getAssociationsBySubject in interface SchemaRegistry

Throws:

SchemaRegistryException

getAssociationsByResourceId

public List<Association> getAssociationsByResourceId(String resourceId,
 String resourceType,
 List<String> associationTypes,
 LifecyclePolicy lifecycle)
                                              throws SchemaRegistryException

Specified by:

getAssociationsByResourceId in interface SchemaRegistry

Throws:

SchemaRegistryException

getAssociationsByResourceName

public List<Association> getAssociationsByResourceName(String resourceName,
 String resourceNamespace,
 String resourceType,
 List<String> associationTypes,
 LifecyclePolicy lifecycle)
                                                throws SchemaRegistryException

Specified by:

getAssociationsByResourceName in interface SchemaRegistry

Throws:

SchemaRegistryException

getAssociationsByResourceNamespace

public List<Association> getAssociationsByResourceNamespace(String resourceNamespace,
 String resourceType,
 List<String> associationTypes,
 LifecyclePolicy lifecycle)
                                                     throws SchemaRegistryException

Specified by:

getAssociationsByResourceNamespace in interface SchemaRegistry

Throws:

SchemaRegistryException