| Package | Description |
|---|---|
| io.confluent.kafka.schemaregistry.storage | |
| io.confluent.kafka.schemaregistry.storage.serialization |
| Modifier and Type | Class and Description |
|---|---|
class |
ClearSubjectKey |
class |
ConfigKey |
class |
ContextKey |
class |
DeleteSubjectKey |
class |
ModeKey |
class |
NoopKey |
class |
SchemaKey |
class |
SubjectKey |
| 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 |
|---|---|
int |
ContextKey.compareTo(SchemaRegistryKey o) |
int |
SchemaRegistryKey.compareTo(SchemaRegistryKey otherKey) |
int |
SchemaKey.compareTo(SchemaRegistryKey o) |
int |
SubjectKey.compareTo(SchemaRegistryKey o) |
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 |
|---|---|
SchemaRegistryKey |
SchemaRegistrySerializer.deserializeKey(byte[] key) |
| Modifier and Type | Method and Description |
|---|---|
SchemaRegistryValue |
SchemaRegistrySerializer.deserializeValue(SchemaRegistryKey key,
byte[] value) |
byte[] |
SchemaRegistrySerializer.serializeKey(SchemaRegistryKey key) |
Copyright © 2026 Confluent, Inc.. All rights reserved.