A D E G I N P R S W

A

ACCESS_KEY_ID - Static variable in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsDriver

AWS_ROLE_ARN - Static variable in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsDriver

AWS_ROLE_EXTERNAL_ID - Static variable in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsDriver

AWS_ROLE_SESSION_NAME - Static variable in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsDriver

AwsKmsAead - Class in io.confluent.kafka.schemaregistry.encryption.aws

A Aead that forwards encryption/decryption requests to a key in AWS KMS.

AwsKmsAead(KmsClient, String) - Constructor for class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsAead

AwsKmsClient - Class in io.confluent.kafka.schemaregistry.encryption.aws

An implementation of KmsClient for AWS KMS.

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

Constructs a generic AwsKmsClient that is not bound to any specific key.

AwsKmsClient(String) - Constructor for class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsClient

Constructs a specific AwsKmsClient that is bound to a single key identified by uri.

AwsKmsDriver - Class in io.confluent.kafka.schemaregistry.encryption.aws

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

D

decrypt(byte[], byte[]) - Method in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsAead

doesSupport(String) - Method in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsClient

E

encrypt(byte[], byte[]) - Method in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsAead

G

getAead(String) - Method in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsClient

getKeyUrlPrefix() - Method in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsDriver

getRegionFromKeyId(String) - Static method in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsDriver

I

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

N

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

newKmsClientWithAwsKms(Optional<String>, Optional<AwsCredentialsProvider>, KmsClient) - Static method in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsDriver

P

PREFIX - Static variable in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsClient

The prefix of all keys stored in AWS KMS.

PROFILE - Static variable in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsDriver

R

register(Optional<String>, Optional<String>) - Static method in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsClient

Creates and registers a AwsKmsClient.AwsKmsClient(java.lang.String) with the Tink runtime.

removePrefix(String, String) - Static method in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsClient

ROLE_ARN - Static variable in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsDriver

ROLE_EXTERNAL_ID - Static variable in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsDriver

ROLE_SESSION_NAME - Static variable in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsDriver

S

SECRET_ACCESS_KEY - Static variable in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsDriver

W

withCredentials(String) - Method in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsClient

Loads AWS credentials from a properties file.

withCredentialsProvider(AwsCredentialsProvider) - Method in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsClient

Loads AWS credentials from a provider.

withDefaultCredentials() - Method in class io.confluent.kafka.schemaregistry.encryption.aws.AwsKmsClient

Loads default AWS credentials.

A D E G I N P R S W