de.saly.kafka.crypto

Class SerdeCryptoBase

java.lang.Object

de.saly.kafka.crypto.SerdeCryptoBase

Direct Known Subclasses:

DecryptingDeserializer, EncryptingSerializer

public abstract class SerdeCryptoBase
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SerdeCryptoBase()

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

CRYPTO_RSA_PRIVATEKEY_FILEPATH

public static final String CRYPTO_RSA_PRIVATEKEY_FILEPATH

See Also:

Constant Field Values

CRYPTO_RSA_PUBLICKEY_FILEPATH

public static final String CRYPTO_RSA_PUBLICKEY_FILEPATH

See Also:

Constant Field Values

CRYPTO_HASH_METHOD

public static final String CRYPTO_HASH_METHOD

See Also:

Constant Field Values

CRYPTO_IGNORE_DECRYPT_FAILURES

public static final String CRYPTO_IGNORE_DECRYPT_FAILURES

See Also:

Constant Field Values

CRYPTO_AES_KEY_LEN

public static final String CRYPTO_AES_KEY_LEN

See Also:

Constant Field Values

DEFAULT_TRANSFORMATION

protected static final String DEFAULT_TRANSFORMATION

See Also:

Constant Field Values

Constructor Detail

SerdeCryptoBase

protected SerdeCryptoBase()

Method Detail

init

protected void init(int opMode,
                    Map<String,?> configs,
                    boolean isKey)
             throws org.apache.kafka.common.KafkaException

Throws:

org.apache.kafka.common.KafkaException

crypt

protected byte[] crypt(byte[] array)
                throws org.apache.kafka.common.KafkaException

Throws:

org.apache.kafka.common.KafkaException

newKey

protected void newKey()

Generate new AES key for the current thread

newInstance

protected <T> T newInstance(Map<String,?> map,
                            String key,
                            Class<T> klass)
                     throws org.apache.kafka.common.KafkaException

Throws:

org.apache.kafka.common.KafkaException

concatenate

public static byte[] concatenate(byte[] a,
                                 byte[] b,
                                 byte[] c,
                                 byte[] d,
                                 byte[] e,
                                 byte[] f)