Package com.amazonaws.athena.connectors.kafka

Class KafkaConstants

java.lang.Object

com.amazonaws.athena.connectors.kafka.KafkaConstants

public class KafkaConstants
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static String	AUTH_TYPE	This is the type of authentication client has set for the cluster
static String	AVRO_DATA_FORMAT
static String	AWS_SECRET_PWD
static String	AWS_SECRET_USERNAME	For scram authentication, we need to fetch the credentials from secrets manager and append to the property file
static String	CERTIFICATES_S3_REFERENCE	For SSL authentication, user need to give S3 bucket reference where the client truststore and keystore files are uploaded.
static String	ENV_KAFKA_ENDPOINT	This is kafka node details
static String	KAFKA_SCHEMA_REGISTRY_URL	This is schema registry url
static String	KAFKA_SOURCE
static String	KEYSTORE_PASSWORD	This is the keystore password
static int	MAX_RECORDS_IN_SPLIT
static String	PROTOBUF_DATA_FORMAT
static String	SECRET_MANAGER_KAFKA_CREDS_NAME	This is secret manager key reference
static String	SSL_KEY_PASSWORD	This is SSL_KEY password
static String	TEMP_DIR	This is temp folder where the certificates from S3 will be downloaded
static String	TRUSTSTORE_PASSWORD	This is the truststore password

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

KAFKA_SOURCE

public static final String KAFKA_SOURCE

See Also:

Constant Field Values

CERTIFICATES_S3_REFERENCE

public static final String CERTIFICATES_S3_REFERENCE

For SSL authentication, user need to give S3 bucket reference where the client truststore and keystore files are uploaded.

See Also:

Constant Field Values

KEYSTORE_PASSWORD

public static final String KEYSTORE_PASSWORD

This is the keystore password

See Also:

Constant Field Values

TRUSTSTORE_PASSWORD

public static final String TRUSTSTORE_PASSWORD

This is the truststore password

See Also:

Constant Field Values

SSL_KEY_PASSWORD

public static final String SSL_KEY_PASSWORD

This is SSL_KEY password

See Also:

Constant Field Values

ENV_KAFKA_ENDPOINT

public static final String ENV_KAFKA_ENDPOINT

This is kafka node details

See Also:

Constant Field Values

KAFKA_SCHEMA_REGISTRY_URL

public static final String KAFKA_SCHEMA_REGISTRY_URL

This is schema registry url

See Also:

Constant Field Values

AUTH_TYPE

public static final String AUTH_TYPE

This is the type of authentication client has set for the cluster

See Also:

Constant Field Values

TEMP_DIR

public static final String TEMP_DIR

This is temp folder where the certificates from S3 will be downloaded

See Also:

Constant Field Values

SECRET_MANAGER_KAFKA_CREDS_NAME

public static final String SECRET_MANAGER_KAFKA_CREDS_NAME

This is secret manager key reference

See Also:

Constant Field Values

AWS_SECRET_USERNAME

public static final String AWS_SECRET_USERNAME

For scram authentication, we need to fetch the credentials from secrets manager and append to the property file

See Also:

Constant Field Values

AWS_SECRET_PWD

public static final String AWS_SECRET_PWD

See Also:

Constant Field Values

MAX_RECORDS_IN_SPLIT

public static final int MAX_RECORDS_IN_SPLIT

See Also:

Constant Field Values

AVRO_DATA_FORMAT

public static final String AVRO_DATA_FORMAT

See Also:

Constant Field Values

PROTOBUF_DATA_FORMAT

public static final String PROTOBUF_DATA_FORMAT

See Also:

Constant Field Values