Uses of Class
io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryStoreException
Packages that use SchemaRegistryStoreException
Package
Description
-
Uses of SchemaRegistryStoreException in io.confluent.kafka.schemaregistry.leaderelector.kafka
Methods in io.confluent.kafka.schemaregistry.leaderelector.kafka that throw SchemaRegistryStoreException -
Uses of SchemaRegistryStoreException in io.confluent.kafka.schemaregistry.storage
Methods in io.confluent.kafka.schemaregistry.storage that throw SchemaRegistryStoreExceptionModifier and TypeMethodDescriptionprotected voidAbstractSchemaRegistry.checkRegisterMode(String subject, Schema schema) voidKafkaSchemaRegistry.deleteConfigOrForward(String subject, Map<String, String> headerProperties) default voidSchemaRegistry.deleteConfigOrForward(String subject, Map<String, String> headerProperties) voidKafkaSchemaRegistry.deleteSubjectConfig(String subject) voidSchemaRegistry.deleteSubjectConfig(String subject) voidKafkaSchemaRegistry.deleteSubjectMode(String subject) voidKafkaSchemaRegistry.deleteSubjectMode(String subject, boolean recursive) voidSchemaRegistry.deleteSubjectMode(String subject) default voidSchemaRegistry.deleteSubjectMode(String subject, boolean recursive) voidKafkaSchemaRegistry.deleteSubjectModeOrForward(String subject, boolean recursive, Map<String, String> headerProperties) default voidSchemaRegistry.deleteSubjectModeOrForward(String subject, boolean recursive, Map<String, String> headerProperties) AbstractSchemaRegistry.getConfigInScope(String subject) SchemaRegistry.getConfigInScope(String subject) AbstractSchemaRegistry.getHostnameVerifier()SchemaRegistry.getHostnameVerifier()AbstractSchemaRegistry.getModeInScope(String subject) SchemaRegistry.getModeInScope(String subject) booleanAbstractSchemaRegistry.hasSubjects(String subject, boolean lookupDeletedSubjects) booleanSchemaRegistry.hasSubjects(String subject, boolean lookupDeletedSubjects) voidLeaderElector.init()protected booleanAbstractSchemaRegistry.isReadOnlyMode(String subject) voidKafkaSchemaRegistry.setLeader(SchemaRegistryIdentity newLeader) 'Inform' this SchemaRegistry instance which SchemaRegistry is the current leader.voidLeaderAwareSchemaRegistry.setLeader(SchemaRegistryIdentity newLeader) default voidSchemaRegistry.setLeader(SchemaRegistryIdentity newLeader) AbstractSchemaRegistry.toSchemaEntity(SchemaValue schemaValue) SchemaRegistry.toSchemaEntity(SchemaValue schemaValue) KafkaSchemaRegistry.updateConfig(String subject, ConfigUpdateRequest config) SchemaRegistry.updateConfig(String subject, ConfigUpdateRequest config) KafkaSchemaRegistry.updateConfigOrForward(String subject, ConfigUpdateRequest newConfig, Map<String, String> headerProperties) default ConfigSchemaRegistry.updateConfigOrForward(String subject, ConfigUpdateRequest newConfig, Map<String, String> headerProperties) -
Uses of SchemaRegistryStoreException in io.confluent.kafka.schemaregistry.storage.encoder
Methods in io.confluent.kafka.schemaregistry.storage.encoder that throw SchemaRegistryStoreExceptionModifier and TypeMethodDescriptionvoidMetadataEncoderService.decodeMetadata(SchemaValue schema) voidMetadataEncoderService.encodeMetadata(SchemaValue schema) abstract com.google.crypto.tink.KeysetHandleMetadataEncoderService.getEncoder(String tenant) protected abstract KeysetWrapperMetadataEncoderService.getEncoderWrapper(String tenant) Get the encoder wrapper for a tenant.protected abstract com.google.crypto.tink.KeysetHandleMetadataEncoderService.getOrCreateEncoder(String tenant) final voidMetadataEncoderService.init()Initialize the metadata encoder service by rotating the secrets if needed.protected voidMetadataEncoderService.maybeRotateSecrets()protected abstract voidMetadataEncoderService.putEncoderWrapper(String tenant, KeysetWrapper wrapper) Store an encoder wrapper for a tenant.