Package io.confluent.kafka.security.config.provider

Class DecryptionEngine

java.lang.Object

io.confluent.kafka.security.config.provider.DecryptionEngine

public class DecryptionEngine
extends Object

DecryptionEngine Engine performs Key loading and decryption operations.

Field Summary

Fields

Modifier and Type	Field	Description
static final Pattern	CIPHER_PATTERN
static final int	GCM_TAG_LENGTH

Constructor Summary

Constructors

Constructor	Description
DecryptionEngine(String masterKeyEnvVar, String dataKeyCipher, String keyLength)

Method Summary

Modifier and Type	Method	Description
String	decryptWithDEK(String encryptedData)
String	decryptWithMasterKey(String encryptedData)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

GCM_TAG_LENGTH

public static final int GCM_TAG_LENGTH

See Also:

• Constant Field Values

CIPHER_PATTERN

public static final Pattern CIPHER_PATTERN

Constructor Details

DecryptionEngine

public DecryptionEngine(String masterKeyEnvVar,
 String dataKeyCipher,
 String keyLength)
                 throws Exception

Throws:

Exception

Method Details

decryptWithMasterKey

public String decryptWithMasterKey(String encryptedData)
                            throws Exception

Throws:

Exception

decryptWithDEK

public String decryptWithDEK(String encryptedData)
                      throws Exception

Throws:

Exception