Package io.confluent.kafka.schemaregistry.storage

Interface SchemaRegistry

All Superinterfaces:

SchemaVersionFetcher

All Known Implementing Classes:

AbstractSchemaRegistry, KafkaSchemaRegistry

public interface SchemaRegistry
extends SchemaVersionFetcher

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_TENANT
static final String	FIELD_CONFLICTS_WITH_RESERVED_FIELD
static final int	MAX_VERSION
static final int	MIN_VERSION	Schema versions under a particular subject are indexed from MIN_VERSION.
static final String	RESERVED_FIELD_REMOVED
static final String	RESOURCE_WILDCARD

Method Summary

Modifier and Type	Method	Description
void	addCustomHandler(org.eclipse.jetty.server.Handler.Singleton handler)
default void	addLeaderChangeListener(Consumer<Boolean> listener)
void	addUpdateRequestHandler(UpdateRequestHandler updateRequestHandler)
default void	clearNewSchemaCache()
default void	clearOldSchemaCache()
void	close()
SchemaRegistryConfig	config()
default AssociationResponse	createAssociation(String context, boolean dryRun, AssociationCreateOrUpdateRequest request)
default AssociationResponse	createAssociationOrForward(String context, boolean dryRun, AssociationCreateOrUpdateRequest request, Map<String,String> headerProperties)
default AssociationResponse	createOrUpdateAssociation(String context, boolean dryRun, AssociationCreateOrUpdateRequest request)
default AssociationResponse	createOrUpdateAssociationOrForward(String context, boolean dryRun, AssociationCreateOrUpdateRequest request, Map<String,String> headerProperties)
default void	deleteAssociations(String resourceId, String resourceType, List<String> associationTypes, boolean cascadeLifecycle)
default void	deleteAssociationsOrForward(String subject, String resourceId, String resourceType, List<String> associationTypes, boolean cascadeLifecycle, boolean dryRun, Map<String,String> headerProperties)
default void	deleteConfigOrForward(String subject, Map<String,String> headerProperties)
void	deleteContext(String delimitedContext)
default void	deleteContextOrForward(Map<String,String> requestProperties, String delimitedContext)
void	deleteSchemaVersion(String subject, Schema schema, boolean permanentDelete)
default 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)
default void	deleteSubjectMode(String subject, boolean recursive)
default void	deleteSubjectModeOrForward(String subject, boolean recursive, Map<String,String> headerProperties)
default List<Integer>	deleteSubjectOrForward(Map<String,String> requestProperties, String subject, boolean permanentDelete)
void	extractSchemaTags(Schema schema, List<String> tags)
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)
default Association	getAssociationByGuid(String guid)
default List<Association>	getAssociationsByResourceId(String resourceId, String resourceType, List<String> associationTypes, LifecyclePolicy lifecycle)
default List<Association>	getAssociationsByResourceName(String resourceName, String resourceNamespace, String resourceType, List<String> associationTypes, LifecyclePolicy lifecycle)
default List<Association>	getAssociationsBySubject(String subject, String resourceType, List<String> associationTypes, LifecyclePolicy lifecycle)
SchemaString	getByGuid(String guid, String format)
default Schema	getByVersion(String subject, int version, boolean returnDeletedSchema)
UpdateRequestHandler	getCompositeUpdateRequestHandler()
Config	getConfig(String subject)
Config	getConfigInScope(String subject)
List<org.eclipse.jetty.server.Handler.Singleton>	getCustomHandler()
default String	getGroupId()
HostnameVerifier	getHostnameVerifier()
default String	getKafkaClusterId()
default KafkaStore<SchemaRegistryKey,SchemaRegistryValue>	getKafkaStore()
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<ContextId>	getReferencedBy(String subject, VersionId versionId, boolean lookupDeletedSchema)
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 latestOnly, Predicate<Schema> postFilter)
boolean	hasSubjects(String subject, boolean lookupDeletedSubjects)
boolean	healthy()
void	init()
boolean	initialized()
default void	invalidateFromNewSchemaCache(Schema schemaKey)
List<String>	isCompatible(String subject, Schema newSchema, List<SchemaKey> previousSchemas, boolean normalize)
default boolean	isLeader()
default SchemaRegistryIdentity	leaderIdentity()
default RestService	leaderRestService()
List<String>	listContexts()
List<ContextId>	listIdsForGuid(String guid)
default Set<String>	listSubjects()
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, boolean lookupDeleted)
default Schema	lookUpSchemaUnderSubject(String subject, Schema schema, boolean lookupDeletedSchema)
Schema	lookUpSchemaUnderSubject(String subject, Schema schema, boolean normalize, boolean lookupDeletedSchema)
Schema	lookUpSchemaUnderSubjectUsingContexts(String subject, Schema schema, boolean normalize, boolean lookupDeletedSchema)
default Schema	modifySchemaTagsOrForward(String subject, Schema schema, TagSchemaRequest request, Map<String,String> headerProperties)
default AssociationBatchResponse	mutateAssociations(String context, boolean dryRun, AssociationBatchRequest request)
default AssociationBatchResponse	mutateAssociationsOrForward(String context, boolean dryRun, AssociationBatchRequest request, Map<String,String> headerProperties)
SchemaRegistryIdentity	myIdentity()
int	normalizeContextLimit(int suppliedLimit)
int	normalizeSchemaLimit(int suppliedLimit)
int	normalizeSubjectLimit(int suppliedLimit)
int	normalizeSubjectVersionLimit(int suppliedLimit)
ParsedSchema	parseSchema(Schema schema)
ParsedSchema	parseSchema(Schema schema, boolean isNew, boolean normalize)
void	postInit()
Map<String,Object>	properties()
default Schema	register(String subject, Schema schema)
default Schema	register(String subject, Schema schema, boolean normalize)
Schema	register(String subject, Schema schema, boolean normalize, boolean propagateSchemaTags)
default Schema	registerOrForward(String subject, RegisterSchemaRequest request, boolean normalize, Map<String,String> headerProperties)
SchemaProvider	schemaProvider(String schemaType)
Set<String>	schemaTypes()
boolean	schemaVersionExists(String subject, VersionId versionId, boolean returnDeletedSchema)
default void	setLeader(SchemaRegistryIdentity newLeader)
void	setMode(String subject, ModeUpdateRequest mode)
void	setMode(String subject, ModeUpdateRequest request, boolean force)
default void	setModeOrForward(String subject, ModeUpdateRequest mode, boolean force, Map<String,String> headerProperties)
void	setRuleSetHandler(RuleSetHandler ruleSetHandler)
default void	setTenant(String tenant)	Can be used by subclasses to implement multi-tenancy
Set<String>	subjects(String subject, boolean lookupDeletedSubjects)
default String	tenant()
Schema	toSchemaEntity(SchemaValue schemaValue)
Config	updateConfig(String subject, ConfigUpdateRequest config)
default Config	updateConfigOrForward(String subject, ConfigUpdateRequest newConfig, Map<String,String> headerProperties)

Field Details

MIN_VERSION

static final int MIN_VERSION

Schema versions under a particular subject are indexed from MIN_VERSION.

See Also:

• Constant Field Values

MAX_VERSION

static final int MAX_VERSION

See Also:

• Constant Field Values

DEFAULT_TENANT

static final String DEFAULT_TENANT

See Also:

• Constant Field Values

RESOURCE_WILDCARD

static final String RESOURCE_WILDCARD

See Also:

• Constant Field Values

RESERVED_FIELD_REMOVED

static final String RESERVED_FIELD_REMOVED

See Also:

• Constant Field Values

FIELD_CONFLICTS_WITH_RESERVED_FIELD

static final String FIELD_CONFLICTS_WITH_RESERVED_FIELD

See Also:

• Constant Field Values

Method Details

init

void init()
   throws SchemaRegistryException

Throws:

SchemaRegistryException

schemaTypes

Set<String> schemaTypes()

register

default Schema register(String subject,
 Schema schema)
                 throws SchemaRegistryException

Throws:

SchemaRegistryException

register

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

Throws:

SchemaRegistryException

register

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

Throws:

SchemaRegistryException

getByVersion

default Schema getByVersion(String subject,
 int version,
 boolean returnDeletedSchema)

Specified by:

getByVersion in interface SchemaVersionFetcher

get

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

Throws:

SchemaRegistryException

get

SchemaString get(int id,
 String subject)
          throws SchemaRegistryException

Throws:

SchemaRegistryException

get

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

Throws:

SchemaRegistryException

listSubjects

default Set<String> listSubjects()
                          throws SchemaRegistryException

Throws:

SchemaRegistryException

listSubjects

Set<String> listSubjects(LookupFilter filter)
                  throws SchemaRegistryException

Throws:

SchemaRegistryException

listSubjectsForId

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

Throws:

SchemaRegistryException

listSubjectsForId

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

Throws:

SchemaRegistryException

getAllVersions

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

Throws:

SchemaRegistryException

getVersionsWithSubjectPrefix

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

Throws:

SchemaRegistryException

getLatestVersion

Schema getLatestVersion(String subject)
                 throws SchemaRegistryException

Throws:

SchemaRegistryException

deleteSubject

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

Throws:

SchemaRegistryException

deleteContext

void deleteContext(String delimitedContext)
            throws SchemaRegistryException

Throws:

SchemaRegistryException

lookUpSchemaUnderSubject

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

Throws:

SchemaRegistryException

lookUpSchemaUnderSubject

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

Throws:

SchemaRegistryException

getLatestWithMetadata

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

Throws:

SchemaRegistryException

isCompatible

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

Throws:

SchemaRegistryException

close

void close()
    throws IOException

Throws:

IOException

deleteSchemaVersion

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

Throws:

SchemaRegistryException

tenant

default String tenant()

Specified by:

tenant in interface SchemaVersionFetcher

setTenant

default void setTenant(String tenant)

Can be used by subclasses to implement multi-tenancy

Parameters:

tenant - the tenant

config

SchemaRegistryConfig config()

properties

Map<String,Object> properties()

getMetadataEncoder

MetadataEncoderService getMetadataEncoder()

addUpdateRequestHandler

void addUpdateRequestHandler(UpdateRequestHandler updateRequestHandler)

getModeInScope

Mode getModeInScope(String subject)
             throws SchemaRegistryStoreException

Throws:

SchemaRegistryStoreException

getCustomHandler

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

postInit

void postInit()
       throws SchemaRegistryException

Throws:

SchemaRegistryException

getCompositeUpdateRequestHandler

UpdateRequestHandler getCompositeUpdateRequestHandler()

normalizeContextLimit

int normalizeContextLimit(int suppliedLimit)

getConfigInScope

Config getConfigInScope(String subject)
                 throws SchemaRegistryStoreException

Throws:

SchemaRegistryStoreException

getConfig

Config getConfig(String subject)
          throws SchemaRegistryStoreException

Throws:

SchemaRegistryStoreException

listContexts

List<String> listContexts()
                   throws SchemaRegistryException

Throws:

SchemaRegistryException

lookUpSchemaUnderSubjectUsingContexts

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

Throws:

SchemaRegistryException

hasSubjects

boolean hasSubjects(String subject,
 boolean lookupDeletedSubjects)
             throws SchemaRegistryStoreException

Throws:

SchemaRegistryStoreException

parseSchema

ParsedSchema parseSchema(Schema schema)
                  throws InvalidSchemaException

Throws:

InvalidSchemaException

parseSchema

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

Throws:

InvalidSchemaException

listSubjectsWithPrefix

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

Throws:

SchemaRegistryException

normalizeSubjectLimit

int normalizeSubjectLimit(int suppliedLimit)

normalizeSchemaLimit

int normalizeSchemaLimit(int suppliedLimit)

extractSchemaTags

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

Throws:

SchemaRegistryException

listVersionsForId

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

Throws:

SchemaRegistryException

normalizeSubjectVersionLimit

int normalizeSubjectVersionLimit(int suppliedLimit)

getByGuid

SchemaString getByGuid(String guid,
 String format)
                throws SchemaRegistryException

Throws:

SchemaRegistryException

listIdsForGuid

List<ContextId> listIdsForGuid(String guid)
                        throws SchemaRegistryException

Throws:

SchemaRegistryException

getUsingContexts

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

Throws:

SchemaRegistryException

getReferencedBy

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

Throws:

SchemaRegistryException

schemaVersionExists

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

Throws:

SchemaRegistryException

getMode

Mode getMode(String subject)
      throws SchemaRegistryStoreException

Throws:

SchemaRegistryStoreException

getMetricsContainer

MetricsContainer getMetricsContainer()

getResourceExtensions

List<SchemaRegistryResourceExtension> getResourceExtensions()

updateConfig

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

Throws:

SchemaRegistryStoreException

OperationNotPermittedException

UnknownLeaderException

deleteSubjectConfig

void deleteSubjectConfig(String subject)
                  throws SchemaRegistryStoreException,
OperationNotPermittedException

Throws:

SchemaRegistryStoreException

OperationNotPermittedException

setMode

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

Throws:

SchemaRegistryException

setMode

void setMode(String subject,
 ModeUpdateRequest mode)
      throws SchemaRegistryException

Throws:

SchemaRegistryException

schemaProvider

SchemaProvider schemaProvider(String schemaType)

toSchemaEntity

Schema toSchemaEntity(SchemaValue schemaValue)
               throws SchemaRegistryStoreException

Throws:

SchemaRegistryStoreException

getSchemaValue

SchemaValue getSchemaValue(SchemaKey key)
                    throws SchemaRegistryException

Throws:

SchemaRegistryException

subjects

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

Throws:

SchemaRegistryStoreException

addCustomHandler

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

deleteSubjectMode

void deleteSubjectMode(String subject)
                throws SchemaRegistryStoreException,
OperationNotPermittedException

Throws:

SchemaRegistryStoreException

OperationNotPermittedException

deleteSubjectMode

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

Throws:

SchemaRegistryStoreException

OperationNotPermittedException

getRuleSetHandler

RuleSetHandler getRuleSetHandler()

setRuleSetHandler

void setRuleSetHandler(RuleSetHandler ruleSetHandler)

getHostnameVerifier

HostnameVerifier getHostnameVerifier()
                              throws SchemaRegistryStoreException

Throws:

SchemaRegistryStoreException

myIdentity

SchemaRegistryIdentity myIdentity()

initialized

boolean initialized()

healthy

boolean healthy()

getSslFactory

SslFactory getSslFactory()

getLookupCache

LookupCache<SchemaRegistryKey,SchemaRegistryValue> getLookupCache()

getKafkaStore

default KafkaStore<SchemaRegistryKey,SchemaRegistryValue> getKafkaStore()

clearOldSchemaCache

default void clearOldSchemaCache()

clearNewSchemaCache

default void clearNewSchemaCache()

invalidateFromNewSchemaCache

default void invalidateFromNewSchemaCache(Schema schemaKey)

getGroupId

default String getGroupId()

getKafkaClusterId

default String getKafkaClusterId()

deleteSubjectModeOrForward

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

Throws:

SchemaRegistryStoreException

SchemaRegistryRequestForwardingException

OperationNotPermittedException

UnknownLeaderException

setModeOrForward

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

Throws:

SchemaRegistryException

deleteSchemaVersionOrForward

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

Throws:

SchemaRegistryException

modifySchemaTagsOrForward

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

Throws:

SchemaRegistryException

registerOrForward

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

Throws:

SchemaRegistryException

deleteSubjectOrForward

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

Throws:

SchemaRegistryException

updateConfigOrForward

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

Throws:

SchemaRegistryStoreException

SchemaRegistryRequestForwardingException

UnknownLeaderException

OperationNotPermittedException

deleteConfigOrForward

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

Throws:

SchemaRegistryStoreException

SchemaRegistryRequestForwardingException

OperationNotPermittedException

UnknownLeaderException

deleteContextOrForward

default void deleteContextOrForward(Map<String,String> requestProperties,
 String delimitedContext)
                             throws SchemaRegistryException

Throws:

SchemaRegistryException

createAssociation

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

Throws:

SchemaRegistryException

createAssociationOrForward

default AssociationResponse createAssociationOrForward(String context,
 boolean dryRun,
 AssociationCreateOrUpdateRequest request,
 Map<String,String> headerProperties)
                                                throws SchemaRegistryException

Throws:

SchemaRegistryException

mutateAssociations

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

mutateAssociationsOrForward

default AssociationBatchResponse mutateAssociationsOrForward(String context,
 boolean dryRun,
 AssociationBatchRequest request,
 Map<String,String> headerProperties)
                                                      throws SchemaRegistryException

Throws:

SchemaRegistryException

createOrUpdateAssociation

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

Throws:

SchemaRegistryException

createOrUpdateAssociationOrForward

default AssociationResponse createOrUpdateAssociationOrForward(String context,
 boolean dryRun,
 AssociationCreateOrUpdateRequest request,
 Map<String,String> headerProperties)
                                                        throws SchemaRegistryException

Throws:

SchemaRegistryException

getAssociationByGuid

default Association getAssociationByGuid(String guid)
                                  throws SchemaRegistryException

Throws:

SchemaRegistryException

getAssociationsBySubject

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

Throws:

SchemaRegistryException

getAssociationsByResourceId

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

Throws:

SchemaRegistryException

getAssociationsByResourceName

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

Throws:

SchemaRegistryException

deleteAssociations

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

Throws:

SchemaRegistryException

deleteAssociationsOrForward

default void deleteAssociationsOrForward(String subject,
 String resourceId,
 String resourceType,
 List<String> associationTypes,
 boolean cascadeLifecycle,
 boolean dryRun,
 Map<String,String> headerProperties)
                                  throws SchemaRegistryException

Throws:

SchemaRegistryException

addLeaderChangeListener

default void addLeaderChangeListener(Consumer<Boolean> listener)

isLeader

default boolean isLeader()

leaderIdentity

default SchemaRegistryIdentity leaderIdentity()

leaderRestService

default RestService leaderRestService()

setLeader

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

Throws:

SchemaRegistryTimeoutException

SchemaRegistryStoreException

IdGenerationException