io.confluent.kafka.schemaregistry.storage

Class KafkaSchemaRegistry

java.lang.Object

io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry

All Implemented Interfaces:

SchemaVersionFetcher, SslFactory.SslFactoryCreated, LeaderAwareSchemaRegistry, SchemaRegistry

public class KafkaSchemaRegistry
extends Object
implements SchemaRegistry, LeaderAwareSchemaRegistry, SslFactory.SslFactoryCreated

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaSchemaRegistry.SchemeAndPort

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_VERSION
static int	MIN_VERSION Schema versions under a particular subject are indexed from MIN_VERSION.

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

DEFAULT_TENANT

Constructor Summary

Constructors

Constructor and Description
KafkaSchemaRegistry(SchemaRegistryConfig config, Serializer<SchemaRegistryKey,SchemaRegistryValue> serializer)

Method Summary

Modifier and Type	Method and Description
void	addCustomHandler(org.eclipse.jetty.server.handler.HandlerWrapper handler)
void	addLeaderChangeListener(Consumer<Boolean> listener) Add a leader change listener.
void	addUpdateRequestHandler(UpdateRequestHandler updateRequestHandler)
Iterator<ExtendedSchema>	allVersionsIncludingAliasesWithSubjectPrefix(String prefix, LookupFilter filter, boolean returnLatestOnly, Predicate<Schema> postFilter)
void	checkIfSchemaWithIdExist(int id, Schema schema)
void	clearNewSchemaCache()
void	clearOldSchemaCache()
void	close()
SchemaRegistryConfig	config()
void	deleteConfigOrForward(String subject, Map<String,String> headerProperties)
void	deleteSchemaVersion(String subject, Schema schema, boolean permanentDelete)
void	deleteSchemaVersionOrForward(Map<String,String> headerProperties, String subject, Schema schema, boolean permanentDelete)
List<Integer>	deleteSubject(String subject, boolean permanentDelete)
void	deleteSubjectConfig(String subject)
void	deleteSubjectMode(String subject)
void	deleteSubjectMode(String subject, boolean recursive)
void	deleteSubjectModeOrForward(String subject, boolean recursive, Map<String,String> headerProperties)
List<Integer>	deleteSubjectOrForward(Map<String,String> requestProperties, String subject, boolean permanentDelete)
void	extractSchemaTags(Schema schema, List<String> tags)
Schema	forwardModifySchemaTagsRequestToLeader(String subject, Schema schema, TagSchemaRequest request, Map<String,String> headerProperties)
SchemaString	get(int id, String subject)
SchemaString	get(int id, String subject, String format, boolean fetchMaxId)
Schema	get(String subject, int version, boolean returnDeletedSchema)
Iterator<SchemaKey>	getAllVersions(String subject, LookupFilter filter)
UpdateRequestHandler	getCompositeUpdateRequestHandler()
Config	getConfig(String subject)
Config	getConfigInScope(String subject)
protected String	getContextPrefixForDeleteMode(String context) Returns the context prefix to use for listing subjects under a given context.
List<org.eclipse.jetty.server.handler.HandlerWrapper>	getCustomHandler()
String	getGroupId()
HostnameVerifier	getHostnameVerifier()
IdGenerator	getIdentityGenerator()
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.
String	getKafkaClusterId()
Schema	getLatestVersion(String subject)
Schema	getLatestWithMetadata(String subject, Map<String,String> metadata, boolean lookupDeletedSchema)
LookupCache<SchemaRegistryKey,SchemaRegistryValue>	getLookupCache()
MetadataEncoderService	getMetadataEncoder()
MetricsContainer	getMetricsContainer()
Mode	getMode(String subject)
Mode	getModeInScope(String subject)
List<Integer>	getReferencedBy(String subject, VersionId versionId)
List<SchemaRegistryResourceExtension>	getResourceExtensions()
RuleSetHandler	getRuleSetHandler()
protected SchemaUpdateHandler	getSchemaUpdateHandler(SchemaRegistryConfig config)
protected SchemaValue	getSchemaValue(SchemaKey key)
Serializer<SchemaRegistryKey,SchemaRegistryValue>	getSerializer()
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)
boolean	healthy()
protected IdGenerator	identityGenerator(SchemaRegistryConfig config)
void	init()
boolean	initialized()
void	invalidateFromNewSchemaCache(Schema schemaKey) Invalidate the cached parsed schema for a new schema.
void	invalidateFromOldSchemaCache(Schema schemaKey) Invalidate the cached parsed schema for an old schema.
List<String>	isCompatible(String subject, Schema newSchema, List<SchemaKey> previousSchemas, boolean normalize)
boolean	isLeader()
protected KafkaStore<SchemaRegistryKey,SchemaRegistryValue>	kafkaStore(SchemaRegistryConfig config)
SchemaRegistryIdentity	leaderIdentity() Return the identity of the SchemaRegistry that this instance thinks is current leader.
RestService	leaderRestService()
List<String>	listContexts()
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 LookupCache<SchemaRegistryKey,SchemaRegistryValue>	lookupCache()
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)
Schema	modifySchemaTags(String subject, Schema schema, TagSchemaRequest request)
Schema	modifySchemaTagsOrForward(String subject, Schema schema, TagSchemaRequest request, Map<String,String> headerProperties)
SchemaRegistryIdentity	myIdentity() Return json data encoding basic information about this SchemaRegistry instance, such as host, port, etc.
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)
void	postInit()
Map<String,Object>	properties()
Schema	register(String subject, RegisterSchemaRequest request, boolean normalize)
Schema	register(String subject, Schema schema, boolean normalize, boolean propagateSchemaTags) Register the given schema under the given subject.
Schema	registerOrForward(String subject, RegisterSchemaRequest request, boolean normalize, Map<String,String> headerProperties)
void	removeCustomHandler(org.eclipse.jetty.server.handler.HandlerWrapper handler)
SchemaProvider	schemaProvider(String schemaType)
Set<String>	schemaTypes()
boolean	schemaVersionExists(String subject, VersionId versionId, boolean returnDeletedSchema)
void	setLeader(SchemaRegistryIdentity newLeader) 'Inform' this SchemaRegistry instance which SchemaRegistry is the current leader.
void	setMode(String subject, ModeUpdateRequest mode)
void	setMode(String subject, ModeUpdateRequest request, boolean force)
void	setModeOrForward(String subject, ModeUpdateRequest mode, boolean force, Map<String,String> headerProperties)
void	setRuleSetHandler(RuleSetHandler ruleSetHandler)
Set<String>	subjects(String subject, boolean lookupDeletedSubjects)
Schema	toSchemaEntity(SchemaValue schemaValue)
Config	updateConfig(String subject, ConfigUpdateRequest config)
Config	updateConfigOrForward(String subject, ConfigUpdateRequest newConfig, Map<String,String> headerProperties)
void	waitForInit()

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

getByVersion, listSubjects, lookUpSchemaUnderSubject, register, register, setTenant, tenant

Field Detail

MIN_VERSION

public static final int MIN_VERSION

Schema versions under a particular subject are indexed from MIN_VERSION.

See Also:

Constant Field Values

MAX_VERSION

public static final int MAX_VERSION

See Also:

Constant Field Values

Constructor Detail

KafkaSchemaRegistry

public KafkaSchemaRegistry(SchemaRegistryConfig config,
                           Serializer<SchemaRegistryKey,SchemaRegistryValue> serializer)
                    throws SchemaRegistryException

Throws:

SchemaRegistryException

Method Detail

kafkaStore

protected KafkaStore<SchemaRegistryKey,SchemaRegistryValue> kafkaStore(SchemaRegistryConfig config)
                                                                throws SchemaRegistryException

Throws:

SchemaRegistryException

getSchemaUpdateHandler

protected SchemaUpdateHandler getSchemaUpdateHandler(SchemaRegistryConfig config)

getResourceExtensions

public List<SchemaRegistryResourceExtension> getResourceExtensions()

lookupCache

protected LookupCache<SchemaRegistryKey,SchemaRegistryValue> lookupCache()

getLookupCache

public LookupCache<SchemaRegistryKey,SchemaRegistryValue> getLookupCache()

getSerializer

public Serializer<SchemaRegistryKey,SchemaRegistryValue> getSerializer()

getMetadataEncoder

public MetadataEncoderService getMetadataEncoder()

getRuleSetHandler

public RuleSetHandler getRuleSetHandler()

setRuleSetHandler

public void setRuleSetHandler(RuleSetHandler ruleSetHandler)

getCompositeUpdateRequestHandler

public UpdateRequestHandler getCompositeUpdateRequestHandler()

addUpdateRequestHandler

public void addUpdateRequestHandler(UpdateRequestHandler updateRequestHandler)

identityGenerator

protected IdGenerator identityGenerator(SchemaRegistryConfig config)

getIdentityGenerator

public IdGenerator getIdentityGenerator()

getMetricsContainer

public MetricsContainer getMetricsContainer()

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

init

public void init()
          throws SchemaRegistryException

Specified by:

init in interface SchemaRegistry

Throws:

SchemaRegistryException

postInit

public void postInit()
              throws SchemaRegistryException

Throws:

SchemaRegistryException

waitForInit

public void waitForInit()
                 throws InterruptedException

Throws:

InterruptedException

initialized

public boolean initialized()

healthy

public boolean healthy()

getSslFactory

public SslFactory getSslFactory()

addLeaderChangeListener

public void addLeaderChangeListener(Consumer<Boolean> listener)

Add a leader change listener.

Parameters:

listener - a function that takes whether this node is a leader

isLeader

public boolean isLeader()

setLeader

public void setLeader(@Nullable
                      SchemaRegistryIdentity newLeader)
               throws SchemaRegistryTimeoutException,
                      SchemaRegistryStoreException,
                      IdGenerationException

'Inform' this SchemaRegistry instance which SchemaRegistry is the current leader. If this instance is set as the new leader, ensure it is up-to-date with data in the kafka store.

Specified by:

setLeader in interface LeaderAwareSchemaRegistry

Parameters:

newLeader - Identity of the current leader. null means no leader is alive.

Throws:

SchemaRegistryTimeoutException

SchemaRegistryStoreException

IdGenerationException

myIdentity

public SchemaRegistryIdentity myIdentity()

Return json data encoding basic information about this SchemaRegistry instance, such as host, port, etc.

leaderIdentity

public SchemaRegistryIdentity leaderIdentity()

Return the identity of the SchemaRegistry that this instance thinks is current leader. Any request that requires writing new data gets forwarded to the leader.

leaderRestService

public RestService leaderRestService()

schemaTypes

public Set<String> schemaTypes()

Specified by:

schemaTypes in interface SchemaRegistry

schemaProvider

public SchemaProvider schemaProvider(String schemaType)

normalizeLimit

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

normalizeSchemaLimit

public int normalizeSchemaLimit(int suppliedLimit)

normalizeSubjectLimit

public int normalizeSubjectLimit(int suppliedLimit)

normalizeContextLimit

public int normalizeContextLimit(int suppliedLimit)

normalizeSubjectVersionLimit

public int normalizeSubjectVersionLimit(int suppliedLimit)

register

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

Throws:

SchemaRegistryException

register

public Schema register(String subject,
                       Schema schema,
                       boolean normalize,
                       boolean propagateSchemaTags)
                throws SchemaRegistryException

Register the given schema under the given subject.

If the schema already exists, it is returned. During registration, the metadata and ruleSet may be populated by the config that is in scope.

Specified by:

register in interface SchemaRegistry

Parameters:

subject - The subject

schema - The schema

normalize - Whether to normalize the schema before registration

Returns:

A schema containing the id. If the schema is different from the input parameter, it is set in the return object.

Throws:

SchemaRegistryException

registerOrForward

public Schema registerOrForward(String subject,
                                RegisterSchemaRequest request,
                                boolean normalize,
                                Map<String,String> headerProperties)
                         throws SchemaRegistryException

Throws:

SchemaRegistryException

extractSchemaTags

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

Throws:

SchemaRegistryException

modifySchemaTags

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

Throws:

SchemaRegistryException

modifySchemaTagsOrForward

public Schema modifySchemaTagsOrForward(String subject,
                                        Schema schema,
                                        TagSchemaRequest request,
                                        Map<String,String> headerProperties)
                                 throws SchemaRegistryException

Throws:

SchemaRegistryException

deleteSchemaVersion

public void deleteSchemaVersion(String subject,
                                Schema schema,
                                boolean permanentDelete)
                         throws SchemaRegistryException

Specified by:

deleteSchemaVersion in interface SchemaRegistry

Throws:

SchemaRegistryException

deleteSchemaVersionOrForward

public void deleteSchemaVersionOrForward(Map<String,String> headerProperties,
                                         String subject,
                                         Schema schema,
                                         boolean permanentDelete)
                                  throws SchemaRegistryException

Throws:

SchemaRegistryException

deleteSubject

public List<Integer> deleteSubject(String subject,
                                   boolean permanentDelete)
                            throws SchemaRegistryException

Specified by:

deleteSubject in interface SchemaRegistry

Throws:

SchemaRegistryException

deleteSubjectOrForward

public List<Integer> deleteSubjectOrForward(Map<String,String> requestProperties,
                                            String subject,
                                            boolean permanentDelete)
                                     throws SchemaRegistryException

Throws:

SchemaRegistryException

lookUpSchemaUnderSubjectUsingContexts

public Schema lookUpSchemaUnderSubjectUsingContexts(String subject,
                                                    Schema schema,
                                                    boolean normalize,
                                                    boolean lookupDeletedSchema)
                                             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

getLatestWithMetadata

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

Specified by:

getLatestWithMetadata in interface SchemaRegistry

Throws:

SchemaRegistryException

checkIfSchemaWithIdExist

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

Throws:

SchemaRegistryException

StoreException

forwardModifySchemaTagsRequestToLeader

public Schema forwardModifySchemaTagsRequestToLeader(String subject,
                                                     Schema schema,
                                                     TagSchemaRequest request,
                                                     Map<String,String> headerProperties)
                                              throws SchemaRegistryRequestForwardingException

Throws:

SchemaRegistryRequestForwardingException

parseSchema

public ParsedSchema parseSchema(Schema schema)
                         throws InvalidSchemaException

Throws:

InvalidSchemaException

parseSchema

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

Throws:

InvalidSchemaException

getUsingContexts

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

Throws:

SchemaRegistryException

schemaVersionExists

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

Throws:

SchemaRegistryException

get

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

Specified by:

get in interface SchemaRegistry

Throws:

SchemaRegistryException

get

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

Specified by:

get in interface SchemaRegistry

Throws:

SchemaRegistryException

get

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

Throws:

SchemaRegistryException

toSchemaEntity

public Schema toSchemaEntity(SchemaValue schemaValue)
                      throws SchemaRegistryStoreException

Throws:

SchemaRegistryStoreException

getSchemaValue

protected SchemaValue getSchemaValue(SchemaKey key)
                              throws SchemaRegistryException

Throws:

SchemaRegistryException

getReferencedBy

public List<Integer> getReferencedBy(String subject,
                                     VersionId versionId)
                              throws SchemaRegistryException

Throws:

SchemaRegistryException

listContexts

public List<String> listContexts()
                          throws SchemaRegistryException

Throws:

SchemaRegistryException

listSubjects

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

Specified by:

listSubjects in interface SchemaRegistry

Throws:

SchemaRegistryException

listSubjectsWithPrefix

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

Throws:

SchemaRegistryException

listSubjectsForId

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

Throws:

SchemaRegistryException

listSubjectsForId

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

Specified by:

listSubjectsForId in interface SchemaRegistry

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

Throws:

SchemaRegistryException

subjects

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

Throws:

SchemaRegistryStoreException

hasSubjects

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

Throws:

SchemaRegistryStoreException

getAllVersions

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

Specified by:

getAllVersions 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

allVersionsIncludingAliasesWithSubjectPrefix

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

Throws:

SchemaRegistryException

getLatestVersion

public Schema getLatestVersion(String subject)
                        throws SchemaRegistryException

Specified by:

getLatestVersion in interface SchemaRegistry

Throws:

SchemaRegistryException

invalidateFromNewSchemaCache

public void invalidateFromNewSchemaCache(Schema schemaKey)

Invalidate the cached parsed schema for a new schema.

Parameters:

schemaKey - a schema key obtained by Schema.toHashKey()

invalidateFromOldSchemaCache

public void invalidateFromOldSchemaCache(Schema schemaKey)

Invalidate the cached parsed schema for an old schema.

Parameters:

schemaKey - a schema key obtained by Schema.toHashKey()

clearNewSchemaCache

public void clearNewSchemaCache()

clearOldSchemaCache

public void clearOldSchemaCache()

close

public void close()
           throws IOException

Specified by:

close in interface SchemaRegistry

Throws:

IOException

updateConfig

public Config updateConfig(String subject,
                           ConfigUpdateRequest config)
                    throws SchemaRegistryStoreException,
                           OperationNotPermittedException,
                           UnknownLeaderException

Throws:

SchemaRegistryStoreException

OperationNotPermittedException

UnknownLeaderException

updateConfigOrForward

public Config updateConfigOrForward(String subject,
                                    ConfigUpdateRequest newConfig,
                                    Map<String,String> headerProperties)
                             throws SchemaRegistryStoreException,
                                    SchemaRegistryRequestForwardingException,
                                    UnknownLeaderException,
                                    OperationNotPermittedException

Throws:

SchemaRegistryStoreException

SchemaRegistryRequestForwardingException

UnknownLeaderException

OperationNotPermittedException

deleteSubjectConfig

public void deleteSubjectConfig(String subject)
                         throws SchemaRegistryStoreException,
                                OperationNotPermittedException

Throws:

SchemaRegistryStoreException

OperationNotPermittedException

deleteConfigOrForward

public void deleteConfigOrForward(String subject,
                                  Map<String,String> headerProperties)
                           throws SchemaRegistryStoreException,
                                  SchemaRegistryRequestForwardingException,
                                  OperationNotPermittedException,
                                  UnknownLeaderException

Throws:

SchemaRegistryStoreException

SchemaRegistryRequestForwardingException

OperationNotPermittedException

UnknownLeaderException

getKafkaClusterId

public String getKafkaClusterId()

getGroupId

public String getGroupId()

getConfig

public Config getConfig(String subject)
                 throws SchemaRegistryStoreException

Throws:

SchemaRegistryStoreException

getConfigInScope

public Config getConfigInScope(String subject)
                        throws SchemaRegistryStoreException

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

getMode

public Mode getMode(String subject)
             throws SchemaRegistryStoreException

Throws:

SchemaRegistryStoreException

getModeInScope

public Mode getModeInScope(String subject)
                    throws SchemaRegistryStoreException

Throws:

SchemaRegistryStoreException

setMode

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

Throws:

SchemaRegistryException

setMode

public void setMode(String subject,
                    ModeUpdateRequest request,
                    boolean force)
             throws SchemaRegistryException

Throws:

SchemaRegistryException

setModeOrForward

public void setModeOrForward(String subject,
                             ModeUpdateRequest mode,
                             boolean force,
                             Map<String,String> headerProperties)
                      throws SchemaRegistryException

Throws:

SchemaRegistryException

deleteSubjectMode

public void deleteSubjectMode(String subject)
                       throws SchemaRegistryStoreException,
                              OperationNotPermittedException

Throws:

SchemaRegistryStoreException

OperationNotPermittedException

deleteSubjectMode

public void deleteSubjectMode(String subject,
                              boolean recursive)
                       throws SchemaRegistryStoreException,
                              OperationNotPermittedException

Throws:

SchemaRegistryStoreException

OperationNotPermittedException

deleteSubjectModeOrForward

public void deleteSubjectModeOrForward(String subject,
                                       boolean recursive,
                                       Map<String,String> headerProperties)
                                throws SchemaRegistryStoreException,
                                       SchemaRegistryRequestForwardingException,
                                       OperationNotPermittedException,
                                       UnknownLeaderException

Throws:

SchemaRegistryStoreException

SchemaRegistryRequestForwardingException

OperationNotPermittedException

UnknownLeaderException

getContextPrefixForDeleteMode

protected String getContextPrefixForDeleteMode(String context)

Returns the context prefix to use for listing subjects under a given context. This method can be overridden in subclasses to customize prefix computation.

Parameters:

context - The normalized context string, or null for default context

Returns:

The subject prefix to use for matching subjects

config

public SchemaRegistryConfig config()

Specified by:

config in interface SchemaRegistry

properties

public Map<String,Object> properties()

Specified by:

properties in interface SchemaRegistry

getHostnameVerifier

public HostnameVerifier getHostnameVerifier()
                                     throws SchemaRegistryStoreException

Throws:

SchemaRegistryStoreException

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

getCustomHandler

public List<org.eclipse.jetty.server.handler.HandlerWrapper> getCustomHandler()

addCustomHandler

public void addCustomHandler(org.eclipse.jetty.server.handler.HandlerWrapper handler)

removeCustomHandler

public void removeCustomHandler(org.eclipse.jetty.server.handler.HandlerWrapper handler)