| Package | Description |
|---|---|
| io.confluent.dekregistry.storage | |
| io.confluent.dekregistry.storage.serialization |
| Modifier and Type | Class and Description |
|---|---|
class |
DataEncryptionKeyId |
class |
KeyEncryptionKeyId |
| Modifier and Type | Method and Description |
|---|---|
abstract EncryptionKeyId |
EncryptionKey.toKey(String tenant) |
| 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 |
|---|---|
int |
EncryptionKeyId.compareTo(EncryptionKeyId that) |
int |
DataEncryptionKeyId.compareTo(EncryptionKeyId o) |
int |
KeyEncryptionKeyId.compareTo(EncryptionKeyId o) |
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 |
|---|---|
EncryptionKeyId |
EncryptionKeyIdDeserializer.deserialize(String topic,
byte[] key) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.kafka.common.serialization.Deserializer<EncryptionKeyId> |
EncryptionKeyIdSerde.deserializer() |
org.apache.kafka.common.serialization.Serializer<EncryptionKeyId> |
EncryptionKeyIdSerde.serializer() |
| Modifier and Type | Method and Description |
|---|---|
byte[] |
EncryptionKeyIdSerializer.serialize(String topic,
EncryptionKeyId key) |
Copyright © 2026 Confluent, Inc.. All rights reserved.