| Package | Description |
|---|---|
| io.confluent.kafka.schemaregistry.storage |
| Modifier and Type | Interface and Description |
|---|---|
interface |
SchemaUpdateHandler |
| Modifier and Type | Class and Description |
|---|---|
class |
CompositeSchemaUpdateHandler |
class |
KafkaStoreMessageHandler |
| 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.