public abstract class SerdeCryptoBase extends Object
| Modifier and Type | Field and Description |
|---|---|
static String |
CRYPTO_AES_KEY_LEN |
static String |
CRYPTO_HASH_METHOD |
static String |
CRYPTO_IGNORE_DECRYPT_FAILURES |
static String |
CRYPTO_RSA_PRIVATEKEY_FILEPATH |
static String |
CRYPTO_RSA_PUBLICKEY_FILEPATH |
protected static String |
DEFAULT_TRANSFORMATION |
| Modifier | Constructor and Description |
|---|---|
protected |
SerdeCryptoBase() |
| Modifier and Type | Method and Description |
|---|---|
static byte[] |
concatenate(byte[] a,
byte[] b,
byte[] c,
byte[] d,
byte[] e,
byte[] f) |
protected byte[] |
crypt(byte[] array) |
protected void |
init(int opMode,
Map<String,?> configs,
boolean isKey) |
protected <T> T |
newInstance(Map<String,?> map,
String key,
Class<T> klass) |
protected void |
newKey()
Generate new AES key for the current thread
|
public static final String CRYPTO_RSA_PRIVATEKEY_FILEPATH
public static final String CRYPTO_RSA_PUBLICKEY_FILEPATH
public static final String CRYPTO_HASH_METHOD
public static final String CRYPTO_IGNORE_DECRYPT_FAILURES
public static final String CRYPTO_AES_KEY_LEN
protected static final String DEFAULT_TRANSFORMATION
protected SerdeCryptoBase()
protected void init(int opMode, Map<String,?> configs, boolean isKey) throws org.apache.kafka.common.KafkaException
org.apache.kafka.common.KafkaExceptionprotected byte[] crypt(byte[] array) throws org.apache.kafka.common.KafkaException
org.apache.kafka.common.KafkaExceptionprotected void newKey()
protected <T> T newInstance(Map<String,?> map, String key, Class<T> klass) throws org.apache.kafka.common.KafkaException
org.apache.kafka.common.KafkaExceptionpublic static byte[] concatenate(byte[] a, byte[] b, byte[] c, byte[] d, byte[] e, byte[] f)
kafka-end-2-end-encryption