Index

A C D E F G I K L M N P R S T V W
All Classes and Interfaces|All Packages|Constant Field Values

A

addOriginalConfigs() - Method in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

addOriginalConfigs() - Method in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor

C

CACHE_EXPIRY_SECS - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

CACHE_EXPIRY_SECS - Static variable in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor

CACHE_SIZE - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

CACHE_SIZE - Static variable in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor

call() - Method in class io.confluent.kafka.schemaregistry.encryption.tools.RegisterDeks

call() - Method in class io.confluent.kafka.schemaregistry.encryption.tools.RewrapDeks

CLOCK - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

CLOCK - Static variable in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor

close() - Method in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

close() - Method in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor

configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor

D

DECRYPTED - Enum constant in enum class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor.Status

Field ciphertext was decrypted to plaintext.

doesSupport(String) - Method in class io.confluent.kafka.schemaregistry.encryption.local.LocalKmsClient

E

EMPTY_AAD - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

EMPTY_AAD - Static variable in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor

ENCRYPT_ALTERNATE_KMS_KEY_IDS - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

ENCRYPT_DEK_ALGORITHM - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

ENCRYPT_DEK_ALGORITHM - Static variable in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor

ENCRYPT_DEK_EXPIRY_DAYS - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

ENCRYPT_DEK_EXPIRY_DAYS - Static variable in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor

ENCRYPT_KEK_NAME - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

ENCRYPT_KEK_NAME - Static variable in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor

ENCRYPT_KMS_KEY_ID - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

ENCRYPT_KMS_KEY_ID - Static variable in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor

ENCRYPT_KMS_TYPE - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

ENCRYPT_KMS_TYPE - Static variable in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor

ENCRYPT_NONSHARED_KEK_PASSTHROUGH - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

EncryptionExecutor - Class in io.confluent.kafka.schemaregistry.encryption

In envelope encryption, a user generates a data encryption key (DEK) locally, encrypts data with the DEK, sends the DEK to a KMS to be encrypted (with a key managed by KMS - KEK), and then stores the encrypted DEK.

EncryptionExecutor() - Constructor for class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

EncryptionExecutor.EncryptionExecutorTransform - Class in io.confluent.kafka.schemaregistry.encryption

EncryptionExecutor.Status - Enum Class in io.confluent.kafka.schemaregistry.encryption

Field-level decryption outcome recorded under EncryptionExecutor.META_STATUS during deserialization.

EncryptionExecutorTransform() - Constructor for class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor.EncryptionExecutorTransform

F

FAILED - Enum constant in enum class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor.Status

Decryption was attempted but threw.

FieldEncryptionExecutor - Class in io.confluent.kafka.schemaregistry.encryption

In envelope encryption, a user generates a data encryption key (DEK) locally, encrypts data with the DEK, sends the DEK to a KMS to be encrypted (with a key managed by KMS - KEK), and then stores the encrypted DEK.

FieldEncryptionExecutor() - Constructor for class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor

FieldEncryptionExecutor.FieldEncryptionExecutorTransform - Class in io.confluent.kafka.schemaregistry.encryption

FieldEncryptionExecutorTransform() - Constructor for class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor.FieldEncryptionExecutorTransform

G

generateDek(DekFormat) - Method in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

getAead(String) - Method in class io.confluent.kafka.schemaregistry.encryption.local.LocalKmsClient

getClock() - Method in class io.confluent.kafka.schemaregistry.encryption.tools.RegisterDeks

getCryptors() - Method in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

getEncryptionExecutor() - Method in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor

getKekName(RuleContext) - Method in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor.EncryptionExecutorTransform

getKeyUrlPrefix() - Method in class io.confluent.kafka.schemaregistry.encryption.local.LocalKmsDriver

getOrCreateDek(RuleContext, Integer) - Method in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor.EncryptionExecutorTransform

getOrCreateKek(RuleContext) - Method in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor.EncryptionExecutorTransform

I

init(RuleContext) - Method in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor.EncryptionExecutorTransform

init(RuleContext) - Method in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor.FieldEncryptionExecutorTransform

io.confluent.kafka.schemaregistry.encryption - package io.confluent.kafka.schemaregistry.encryption

io.confluent.kafka.schemaregistry.encryption.local - package io.confluent.kafka.schemaregistry.encryption.local

io.confluent.kafka.schemaregistry.encryption.tools - package io.confluent.kafka.schemaregistry.encryption.tools

isDekRotated() - Method in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor.EncryptionExecutorTransform

K

KMS_TYPE_SUFFIX - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

KMS_TYPE_SUFFIX - Static variable in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor

L

LATEST_VERSION - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

LOCAL_SECRET - Static variable in class io.confluent.kafka.schemaregistry.encryption.local.LocalKmsDriver

LocalKmsClient - Class in io.confluent.kafka.schemaregistry.encryption.local

An implementation of local KmsClient for testing.

LocalKmsClient(String, String) - Constructor for class io.confluent.kafka.schemaregistry.encryption.local.LocalKmsClient

LocalKmsDriver - Class in io.confluent.kafka.schemaregistry.encryption.local

LocalKmsDriver() - Constructor for class io.confluent.kafka.schemaregistry.encryption.local.LocalKmsDriver

M

MAGIC_BYTE - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

main(String[]) - Static method in class io.confluent.kafka.schemaregistry.encryption.tools.RegisterDeks

main(String[]) - Static method in class io.confluent.kafka.schemaregistry.encryption.tools.RewrapDeks

META_DEK_VERSION - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

Per-field metadata key for the DEK version that decrypted the field.

META_ERROR_MESSAGE - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

Per-field metadata key for the failure message when status is FAILED.

META_KEK_NAME - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

Per-field metadata key for the KEK name resolved for the field.

META_STATUS - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

Per-field metadata key set by this executor in RuleResult.fieldMetadata().get(fieldPath).

MILLIS_IN_DAY - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

N

newKmsClient(Map<String, ?>, Optional<String>) - Method in class io.confluent.kafka.schemaregistry.encryption.local.LocalKmsDriver

newTransform(RuleContext) - Method in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

newTransform(RuleContext) - Method in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor

P

PASSTHROUGH - Enum constant in enum class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor.Status

Field was left as ciphertext because the executor was configured for passthrough (non-shared KEK).

PREFIX - Static variable in class io.confluent.kafka.schemaregistry.encryption.local.LocalKmsClient

The prefix of all keys stored in Local KMS.

R

RegisterDeks - Class in io.confluent.kafka.schemaregistry.encryption.tools

RegisterDeks() - Constructor for class io.confluent.kafka.schemaregistry.encryption.tools.RegisterDeks

RewrapDeks - Class in io.confluent.kafka.schemaregistry.encryption.tools

RewrapDeks() - Constructor for class io.confluent.kafka.schemaregistry.encryption.tools.RewrapDeks

S

SECRET - Static variable in class io.confluent.kafka.schemaregistry.encryption.local.LocalKmsDriver

setClock(Clock) - Method in class io.confluent.kafka.schemaregistry.encryption.tools.RegisterDeks

setSchemaRegistryClient(SchemaRegistryClient) - Method in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

setSchemaRegistryClient(SchemaRegistryClient) - Method in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor

T

transform(RuleContext, RuleContext.FieldContext, Object) - Method in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor.FieldEncryptionExecutorTransform

transform(RuleContext, RuleContext.Type, Object) - Method in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor.EncryptionExecutorTransform

transform(RuleContext, Object) - Method in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

type() - Method in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

type() - Method in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor

TYPE - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

TYPE - Static variable in class io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor

V

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor.Status

Returns the enum constant of this class with the specified name.

values() - Static method in enum class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor.Status

Returns an array containing the constants of this enum class, in the order they are declared.

VERSION_SIZE - Static variable in class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor

W

withCredentials(String) - Method in class io.confluent.kafka.schemaregistry.encryption.local.LocalKmsClient

Loads credentials from a properties file.

withDefaultCredentials() - Method in class io.confluent.kafka.schemaregistry.encryption.local.LocalKmsClient

Loads default credentials.

A C D E F G I K L M N P R S T V W
All Classes and Interfaces|All Packages|Constant Field Values