| Package | Description |
|---|---|
| io.confluent.kafka.schemaregistry.storage | |
| io.confluent.kafka.schemaregistry.storage.serialization |
| Modifier and Type | Method and Description |
|---|---|
Serializer<SchemaRegistryKey,SchemaRegistryValue> |
KafkaSchemaRegistry.getSerializer() |
| Constructor and Description |
|---|
InMemoryCache(Serializer<K,V> serializer) |
KafkaSchemaRegistry(SchemaRegistryConfig config,
Serializer<SchemaRegistryKey,SchemaRegistryValue> serializer) |
KafkaStore(SchemaRegistryConfig config,
StoreUpdateHandler<K,V> storeUpdateHandler,
Serializer<K,V> serializer,
Store<K,V> localStore,
K noopKey) |
KafkaStoreReaderThread(String bootstrapBrokers,
String topic,
String groupId,
StoreUpdateHandler<K,V> storeUpdateHandler,
Serializer<K,V> serializer,
Store<K,V> localStore,
org.apache.kafka.clients.producer.Producer<byte[],byte[]> producer,
K noopKey,
AtomicBoolean initialized,
SchemaRegistryConfig config) |
| Modifier and Type | Class and Description |
|---|---|
class |
SchemaRegistrySerializer |
Copyright © 2026 Confluent, Inc.. All rights reserved.