| Package | Description |
|---|---|
| io.confluent.kafka.schemaregistry.storage |
| Modifier and Type | Interface and Description |
|---|---|
interface |
LookupCache<K,V>
Internal interface that provides various indexed methods that help lookup the underlying schemas.
|
| Modifier and Type | Class and Description |
|---|---|
class |
InMemoryCache<K,V>
In-memory store based on maps
|
class |
KafkaStore<K,V> |
| Constructor and Description |
|---|
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) |
Copyright © 2026 Confluent, Inc.. All rights reserved.