| Package | Description |
|---|---|
| io.confluent.dekregistry.storage | |
| io.confluent.dekregistry.storage.serialization |
| Modifier and Type | Class and Description |
|---|---|
class |
DataEncryptionKey |
class |
KeyEncryptionKey |
| Modifier and Type | Method and Description |
|---|---|
protected List<io.kcache.KeyValue<EncryptionKeyId,EncryptionKey>> |
DekRegistry.getDeks(String tenant,
boolean lookupDeleted) |
protected List<io.kcache.KeyValue<EncryptionKeyId,EncryptionKey>> |
DekRegistry.getDeks(String tenant,
String kekName,
boolean lookupDeleted) |
protected List<io.kcache.KeyValue<EncryptionKeyId,EncryptionKey>> |
DekRegistry.getDeks(String tenant,
String minKekName,
String maxKekName,
boolean lookupDeleted) |
protected List<io.kcache.KeyValue<EncryptionKeyId,EncryptionKey>> |
DekRegistry.getDeks(String tenant,
String kekName,
String subject,
DekFormat algorithm,
boolean lookupDeleted) |
protected List<io.kcache.KeyValue<EncryptionKeyId,EncryptionKey>> |
DekRegistry.getKeks(String tenant,
boolean lookupDeleted) |
io.kcache.Cache<EncryptionKeyId,EncryptionKey> |
DekRegistry.keys() |
| Modifier and Type | Method and Description |
|---|---|
void |
DefaultDekCacheUpdateHandler.handleUpdate(EncryptionKeyId key,
EncryptionKey value,
EncryptionKey oldValue,
org.apache.kafka.common.TopicPartition tp,
long offset,
long timestamp)
Invoked on every new schema written to the Kafka store
|
io.kcache.CacheUpdateHandler.ValidationStatus |
DefaultDekCacheUpdateHandler.validateUpdate(EncryptionKeyId key,
EncryptionKey value,
org.apache.kafka.common.TopicPartition tp,
long offset,
long timestamp) |
| Modifier and Type | Method and Description |
|---|---|
EncryptionKey |
EncryptionKeyDeserializer.deserialize(String topic,
byte[] key) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.kafka.common.serialization.Deserializer<EncryptionKey> |
EncryptionKeySerde.deserializer() |
org.apache.kafka.common.serialization.Serializer<EncryptionKey> |
EncryptionKeySerde.serializer() |
| Modifier and Type | Method and Description |
|---|---|
byte[] |
EncryptionKeySerializer.serialize(String topic,
EncryptionKey key) |
Copyright © 2026 Confluent, Inc.. All rights reserved.