| Package | Description |
|---|---|
| io.confluent.kafka.schemaregistry.storage | |
| io.confluent.kafka.schemaregistry.storage.serialization |
| Modifier and Type | Class and Description |
|---|---|
class |
ClearSubjectValue |
class |
ConfigValue |
class |
ContextValue |
class |
DeleteSubjectValue |
class |
ModeValue |
class |
SchemaValue |
class |
SubjectValue |
| Modifier and Type | Method and Description |
|---|---|
LookupCache<SchemaRegistryKey,SchemaRegistryValue> |
KafkaSchemaRegistry.getLookupCache() |
Serializer<SchemaRegistryKey,SchemaRegistryValue> |
KafkaSchemaRegistry.getSerializer() |
protected KafkaStore<SchemaRegistryKey,SchemaRegistryValue> |
KafkaSchemaRegistry.kafkaStore(SchemaRegistryConfig config) |
protected LookupCache<SchemaRegistryKey,SchemaRegistryValue> |
KafkaSchemaRegistry.lookupCache() |
| Modifier and Type | Method and Description |
|---|---|
void |
KafkaStoreMessageHandler.handleUpdate(SchemaRegistryKey key,
SchemaRegistryValue value,
SchemaRegistryValue oldValue,
org.apache.kafka.common.TopicPartition tp,
long offset,
long timestamp)
Invoked on every new schema written to the Kafka store
|
void |
CompositeSchemaUpdateHandler.handleUpdate(SchemaRegistryKey key,
SchemaRegistryValue value,
SchemaRegistryValue oldValue,
org.apache.kafka.common.TopicPartition tp,
long offset,
long timestamp)
Invoked on every new schema written to the Kafka store
|
StoreUpdateHandler.ValidationStatus |
KafkaStoreMessageHandler.validateUpdate(SchemaRegistryKey key,
SchemaRegistryValue value,
org.apache.kafka.common.TopicPartition tp,
long offset,
long timestamp)
Invoked before every new K,V pair written to the store
|
StoreUpdateHandler.ValidationStatus |
CompositeSchemaUpdateHandler.validateUpdate(SchemaRegistryKey key,
SchemaRegistryValue value,
org.apache.kafka.common.TopicPartition tp,
long offset,
long timestamp)
Invoked before every new K,V pair written to the store
|
| Constructor and Description |
|---|
KafkaSchemaRegistry(SchemaRegistryConfig config,
Serializer<SchemaRegistryKey,SchemaRegistryValue> serializer) |
KafkaStoreMessageHandler(KafkaSchemaRegistry schemaRegistry,
LookupCache<SchemaRegistryKey,SchemaRegistryValue> lookupCache,
IdGenerator idGenerator) |
| Modifier and Type | Method and Description |
|---|---|
SchemaRegistryValue |
SchemaRegistrySerializer.deserializeValue(SchemaRegistryKey key,
byte[] value) |
| Modifier and Type | Method and Description |
|---|---|
byte[] |
SchemaRegistrySerializer.serializeValue(SchemaRegistryValue value) |
Copyright © 2026 Confluent, Inc.. All rights reserved.