Index
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
- 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
- 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
- EncryptionExecutorTransform() - Constructor for class io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor.EncryptionExecutorTransform
F
- 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
KmsClientfor 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
- 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
- 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
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
- 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.
All Classes and Interfaces|All Packages|Constant Field Values