com.amazonaws.services.kinesis.connectors

Class KinesisConnectorConfiguration

java.lang.Object

com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

public class KinesisConnectorConfiguration
extends Object

This class contains constants used to configure AWS Services in Amazon Kinesis Connectors. The user should use System properties to set their proper configuration. An instance of KinesisConnectorConfiguration is created with System properties and an AWSCredentialsProvider. For example:

 Properties prop = new Properties();
 prop.put(KinesisConnectorConfiguration.PROP_APP_NAME, "MyKinesisConnector");
 KinesisConnectorConfiguration config =
         new KinesisConnectorConfiguration(prop, new DefaultAWSCredentialsProviderChain());
 

Field Summary

Fields

Modifier and Type	Field and Description
String	APP_NAME
com.amazonaws.auth.AWSCredentialsProvider	AWS_CREDENTIALS_PROVIDER
long	BACKOFF_INTERVAL
boolean	BATCH_RECORDS_IN_PUT_REQUEST
long	BUFFER_BYTE_SIZE_LIMIT
long	BUFFER_MILLISECONDS_LIMIT
long	BUFFER_RECORD_COUNT_LIMIT
boolean	CALL_PROCESS_RECORDS_EVEN_FOR_EMPTY_LIST
boolean	CLEANUP_TERMINATED_SHARDS_BEFORE_EXPIRY
long	CLOUDWATCH_BUFFER_TIME
int	CLOUDWATCH_MAX_QUEUE_SIZE
String	CLOUDWATCH_NAMESPACE
String	CONNECTOR_DESTINATION
static String	DEFAULT_APP_NAME
static long	DEFAULT_BACKOFF_INTERVAL
static boolean	DEFAULT_BATCH_RECORDS_IN_PUT_REQUEST
static long	DEFAULT_BUFFER_BYTE_SIZE_LIMIT
static long	DEFAULT_BUFFER_MILLISECONDS_LIMIT
static long	DEFAULT_BUFFER_RECORD_COUNT_LIMIT
static boolean	DEFAULT_CALL_PROCESS_RECORDS_EVEN_FOR_EMPTY_LIST
static boolean	DEFAULT_CLEANUP_TERMINATED_SHARDS_BEFORE_EXPIRY
static long	DEFAULT_CLOUDWATCH_BUFFER_TIME
static int	DEFAULT_CLOUDWATCH_MAX_QUEUE_SIZE
static String	DEFAULT_CLOUDWATCH_NAMESPACE
static String	DEFAULT_CONNECTOR_DESTINATION
static String	DEFAULT_DYNAMODB_DATA_TABLE_NAME
static String	DEFAULT_DYNAMODB_ENDPOINT
static String	DEFAULT_ELASTICSEARCH_CLOUDFORMATION_CLUSTER_INSTANCE_TYPE
static String	DEFAULT_ELASTICSEARCH_CLOUDFORMATION_CLUSTER_SIZE
static String	DEFAULT_ELASTICSEARCH_CLOUDFORMATION_KEY_PAIR_NAME
static String	DEFAULT_ELASTICSEARCH_CLOUDFORMATION_SSH_LOCATION
static String	DEFAULT_ELASTICSEARCH_CLOUDFORMATION_STACK_NAME
static String	DEFAULT_ELASTICSEARCH_CLOUDFORMATION_TEMPLATE_URL
static String	DEFAULT_ELASTICSEARCH_CLUSTER_NAME
static String	DEFAULT_ELASTICSEARCH_DEFAULT_INDEX_NAME
static String	DEFAULT_ELASTICSEARCH_DEFAULT_TYPE_NAME
static String	DEFAULT_ELASTICSEARCH_ENDPOINT
static boolean	DEFAULT_ELASTICSEARCH_IGNORE_CLUSTER_NAME
static String	DEFAULT_ELASTICSEARCH_NODE_SAMPLER_INTERVAL
static String	DEFAULT_ELASTICSEARCH_PING_TIMEOUT
static int	DEFAULT_ELASTICSEARCH_PORT
static boolean	DEFAULT_ELASTICSEARCH_TRANSPORT_SNIFF
static String	DEFAULT_ELASTICSEARCH_VERSION_NUMBER
static long	DEFAULT_FAILOVER_TIME
static long	DEFAULT_IDLE_TIME_BETWEEN_READS
static com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStream	DEFAULT_INITIAL_POSITION_IN_STREAM
static String	DEFAULT_KINESIS_ENDPOINT
static String	DEFAULT_KINESIS_INPUT_STREAM
static String	DEFAULT_KINESIS_OUTPUT_STREAM
static int	DEFAULT_KINESIS_STREAM_SHARD_COUNT
static int	DEFAULT_MAX_RECORDS
static long	DEFAULT_PARENT_SHARD_POLL_INTERVAL
static boolean	DEFAULT_REDSHIFT_COPY_MANDATORY
static Character	DEFAULT_REDSHIFT_DATA_DELIMITER
static String	DEFAULT_REDSHIFT_DATA_TABLE
static String	DEFAULT_REDSHIFT_ENDPOINT
static String	DEFAULT_REDSHIFT_FILE_KEY_COLUMN
static String	DEFAULT_REDSHIFT_FILE_TABLE
static String	DEFAULT_REDSHIFT_PASSWORD
static String	DEFAULT_REDSHIFT_URL
static String	DEFAULT_REDSHIFT_USERNAME
static String	DEFAULT_REGION_NAME
static int	DEFAULT_RETRY_LIMIT
static String	DEFAULT_S3_BUCKET
static String	DEFAULT_S3_ENDPOINT
static long	DEFAULT_SHARD_SYNC_INTERVAL
static String	DEFAULT_WORKER_ID
String	DYNAMODB_DATA_TABLE_NAME
String	DYNAMODB_ENDPOINT
String	ELASTICSEARCH_CLOUDFORMATION_CLUSTER_INSTANCE_TYPE
String	ELASTICSEARCH_CLOUDFORMATION_CLUSTER_SIZE
String	ELASTICSEARCH_CLOUDFORMATION_KEY_PAIR_NAME
String	ELASTICSEARCH_CLOUDFORMATION_SSH_LOCATION
String	ELASTICSEARCH_CLOUDFORMATION_STACK_NAME
String	ELASTICSEARCH_CLOUDFORMATION_TEMPLATE_URL
String	ELASTICSEARCH_CLUSTER_NAME
String	ELASTICSEARCH_DEFAULT_INDEX_NAME
String	ELASTICSEARCH_DEFAULT_TYPE_NAME
String	ELASTICSEARCH_ENDPOINT
boolean	ELASTICSEARCH_IGNORE_CLUSTER_NAME
String	ELASTICSEARCH_NODE_SAMPLER_INTERVAL
String	ELASTICSEARCH_PING_TIMEOUT
int	ELASTICSEARCH_PORT
boolean	ELASTICSEARCH_TRANSPORT_SNIFF
String	ELASTICSEARCH_VERSION_NUMBER
long	FAILOVER_TIME
long	IDLE_TIME_BETWEEN_READS
com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStream	INITIAL_POSITION_IN_STREAM
static String	KINESIS_CONNECTOR_USER_AGENT
String	KINESIS_ENDPOINT
String	KINESIS_INPUT_STREAM
int	KINESIS_INPUT_STREAM_SHARD_COUNT
String	KINESIS_OUTPUT_STREAM
int	KINESIS_OUTPUT_STREAM_SHARD_COUNT
int	MAX_RECORDS
long	PARENT_SHARD_POLL_INTERVAL
static String	PROP_APP_NAME
static String	PROP_BACKOFF_INTERVAL
static String	PROP_BATCH_RECORDS_IN_PUT_REQUEST
static String	PROP_BUFFER_BYTE_SIZE_LIMIT
static String	PROP_BUFFER_MILLISECONDS_LIMIT
static String	PROP_BUFFER_RECORD_COUNT_LIMIT
static String	PROP_CALL_PROCESS_RECORDS_EVEN_FOR_EMPTY_LIST
static String	PROP_CLEANUP_TERMINATED_SHARDS_BEFORE_EXPIRY
static String	PROP_CLOUDWATCH_BUFFER_TIME
static String	PROP_CLOUDWATCH_MAX_QUEUE_SIZE
static String	PROP_CLOUDWATCH_NAMESPACE
static String	PROP_CONNECTOR_DESTINATION
static String	PROP_DYNAMODB_DATA_TABLE_NAME
static String	PROP_DYNAMODB_ENDPOINT
static String	PROP_ELASTICSEARCH_CLOUDFORMATION_CLUSTER_INSTANCE_TYPE
static String	PROP_ELASTICSEARCH_CLOUDFORMATION_CLUSTER_SIZE
static String	PROP_ELASTICSEARCH_CLOUDFORMATION_KEY_PAIR_NAME
static String	PROP_ELASTICSEARCH_CLOUDFORMATION_SSH_LOCATION
static String	PROP_ELASTICSEARCH_CLOUDFORMATION_STACK_NAME
static String	PROP_ELASTICSEARCH_CLOUDFORMATION_TEMPLATE_URL
static String	PROP_ELASTICSEARCH_CLUSTER_NAME
static String	PROP_ELASTICSEARCH_DEFAULT_INDEX_NAME
static String	PROP_ELASTICSEARCH_DEFAULT_TYPE_NAME
static String	PROP_ELASTICSEARCH_ENDPOINT
static String	PROP_ELASTICSEARCH_IGNORE_CLUSTER_NAME
static String	PROP_ELASTICSEARCH_NODE_SAMPLER_INTERVAL
static String	PROP_ELASTICSEARCH_PING_TIMEOUT
static String	PROP_ELASTICSEARCH_PORT
static String	PROP_ELASTICSEARCH_TRANSPORT_SNIFF
static String	PROP_ELASTICSEARCH_VERSION_NUMBER
static String	PROP_FAILOVER_TIME
static String	PROP_IDLE_TIME_BETWEEN_READS
static String	PROP_INITIAL_POSITION_IN_STREAM
static String	PROP_KINESIS_ENDPOINT
static String	PROP_KINESIS_INPUT_STREAM
static String	PROP_KINESIS_INPUT_STREAM_SHARD_COUNT
static String	PROP_KINESIS_OUTPUT_STREAM
static String	PROP_KINESIS_OUTPUT_STREAM_SHARD_COUNT
static String	PROP_MAX_RECORDS
static String	PROP_PARENT_SHARD_POLL_INTERVAL
static String	PROP_REDSHIFT_COPY_MANDATORY
static String	PROP_REDSHIFT_DATA_DELIMITER
static String	PROP_REDSHIFT_DATA_TABLE
static String	PROP_REDSHIFT_ENDPOINT
static String	PROP_REDSHIFT_FILE_KEY_COLUMN
static String	PROP_REDSHIFT_FILE_TABLE
static String	PROP_REDSHIFT_PASSWORD
static String	PROP_REDSHIFT_URL
static String	PROP_REDSHIFT_USERNAME
static String	PROP_REGION_NAME
static String	PROP_RETRY_LIMIT
static String	PROP_S3_BUCKET
static String	PROP_S3_ENDPOINT
static String	PROP_SHARD_SYNC_INTERVAL
static String	PROP_WORKER_ID
boolean	REDSHIFT_COPY_MANDATORY
Character	REDSHIFT_DATA_DELIMITER
String	REDSHIFT_DATA_TABLE
String	REDSHIFT_ENDPOINT
String	REDSHIFT_FILE_KEY_COLUMN
String	REDSHIFT_FILE_TABLE
String	REDSHIFT_PASSWORD
String	REDSHIFT_URL
String	REDSHIFT_USERNAME
String	REGION_NAME
int	RETRY_LIMIT
String	S3_BUCKET
String	S3_ENDPOINT
long	SHARD_SYNC_INTERVAL
String	WORKER_ID

Constructor Summary

Constructors

Constructor and Description
KinesisConnectorConfiguration(Properties properties, com.amazonaws.auth.AWSCredentialsProvider credentialsProvider) Configure the connector application with any set of properties that are unique to the application.

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

KINESIS_CONNECTOR_USER_AGENT

public static final String KINESIS_CONNECTOR_USER_AGENT

See Also:

Constant Field Values

PROP_APP_NAME

public static final String PROP_APP_NAME

See Also:

Constant Field Values

PROP_CONNECTOR_DESTINATION

public static final String PROP_CONNECTOR_DESTINATION

See Also:

Constant Field Values

PROP_RETRY_LIMIT

public static final String PROP_RETRY_LIMIT

See Also:

Constant Field Values

PROP_BACKOFF_INTERVAL

public static final String PROP_BACKOFF_INTERVAL

See Also:

Constant Field Values

PROP_KINESIS_ENDPOINT

public static final String PROP_KINESIS_ENDPOINT

See Also:

Constant Field Values

PROP_KINESIS_INPUT_STREAM

public static final String PROP_KINESIS_INPUT_STREAM

See Also:

Constant Field Values

PROP_KINESIS_INPUT_STREAM_SHARD_COUNT

public static final String PROP_KINESIS_INPUT_STREAM_SHARD_COUNT

See Also:

Constant Field Values

PROP_KINESIS_OUTPUT_STREAM

public static final String PROP_KINESIS_OUTPUT_STREAM

See Also:

Constant Field Values

PROP_KINESIS_OUTPUT_STREAM_SHARD_COUNT

public static final String PROP_KINESIS_OUTPUT_STREAM_SHARD_COUNT

See Also:

Constant Field Values

PROP_WORKER_ID

public static final String PROP_WORKER_ID

See Also:

Constant Field Values

PROP_FAILOVER_TIME

public static final String PROP_FAILOVER_TIME

See Also:

Constant Field Values

PROP_MAX_RECORDS

public static final String PROP_MAX_RECORDS

See Also:

Constant Field Values

PROP_INITIAL_POSITION_IN_STREAM

public static final String PROP_INITIAL_POSITION_IN_STREAM

See Also:

Constant Field Values

PROP_IDLE_TIME_BETWEEN_READS

public static final String PROP_IDLE_TIME_BETWEEN_READS

See Also:

Constant Field Values

PROP_PARENT_SHARD_POLL_INTERVAL

public static final String PROP_PARENT_SHARD_POLL_INTERVAL

See Also:

Constant Field Values

PROP_SHARD_SYNC_INTERVAL

public static final String PROP_SHARD_SYNC_INTERVAL

See Also:

Constant Field Values

PROP_CALL_PROCESS_RECORDS_EVEN_FOR_EMPTY_LIST

public static final String PROP_CALL_PROCESS_RECORDS_EVEN_FOR_EMPTY_LIST

See Also:

Constant Field Values

PROP_CLEANUP_TERMINATED_SHARDS_BEFORE_EXPIRY

public static final String PROP_CLEANUP_TERMINATED_SHARDS_BEFORE_EXPIRY

See Also:

Constant Field Values

PROP_REGION_NAME

public static final String PROP_REGION_NAME

See Also:

Constant Field Values

PROP_BATCH_RECORDS_IN_PUT_REQUEST

public static final String PROP_BATCH_RECORDS_IN_PUT_REQUEST

See Also:

Constant Field Values

PROP_S3_ENDPOINT

public static final String PROP_S3_ENDPOINT

See Also:

Constant Field Values

PROP_S3_BUCKET

public static final String PROP_S3_BUCKET

See Also:

Constant Field Values

PROP_REDSHIFT_ENDPOINT

public static final String PROP_REDSHIFT_ENDPOINT

See Also:

Constant Field Values

PROP_REDSHIFT_USERNAME

public static final String PROP_REDSHIFT_USERNAME

See Also:

Constant Field Values

PROP_REDSHIFT_PASSWORD

public static final String PROP_REDSHIFT_PASSWORD

See Also:

Constant Field Values

PROP_REDSHIFT_URL

public static final String PROP_REDSHIFT_URL

See Also:

Constant Field Values

PROP_REDSHIFT_DATA_TABLE

public static final String PROP_REDSHIFT_DATA_TABLE

See Also:

Constant Field Values

PROP_REDSHIFT_FILE_TABLE

public static final String PROP_REDSHIFT_FILE_TABLE

See Also:

Constant Field Values

PROP_REDSHIFT_FILE_KEY_COLUMN

public static final String PROP_REDSHIFT_FILE_KEY_COLUMN

See Also:

Constant Field Values

PROP_REDSHIFT_DATA_DELIMITER

public static final String PROP_REDSHIFT_DATA_DELIMITER

See Also:

Constant Field Values

PROP_REDSHIFT_COPY_MANDATORY

public static final String PROP_REDSHIFT_COPY_MANDATORY

See Also:

Constant Field Values

PROP_BUFFER_RECORD_COUNT_LIMIT

public static final String PROP_BUFFER_RECORD_COUNT_LIMIT

See Also:

Constant Field Values

PROP_BUFFER_BYTE_SIZE_LIMIT

public static final String PROP_BUFFER_BYTE_SIZE_LIMIT

See Also:

Constant Field Values

PROP_BUFFER_MILLISECONDS_LIMIT

public static final String PROP_BUFFER_MILLISECONDS_LIMIT

See Also:

Constant Field Values

PROP_DYNAMODB_ENDPOINT

public static final String PROP_DYNAMODB_ENDPOINT

See Also:

Constant Field Values

PROP_DYNAMODB_DATA_TABLE_NAME

public static final String PROP_DYNAMODB_DATA_TABLE_NAME

See Also:

Constant Field Values

PROP_CLOUDWATCH_NAMESPACE

public static final String PROP_CLOUDWATCH_NAMESPACE

See Also:

Constant Field Values

PROP_CLOUDWATCH_BUFFER_TIME

public static final String PROP_CLOUDWATCH_BUFFER_TIME

See Also:

Constant Field Values

PROP_CLOUDWATCH_MAX_QUEUE_SIZE

public static final String PROP_CLOUDWATCH_MAX_QUEUE_SIZE

See Also:

Constant Field Values

PROP_ELASTICSEARCH_CLUSTER_NAME

public static final String PROP_ELASTICSEARCH_CLUSTER_NAME

See Also:

Constant Field Values

PROP_ELASTICSEARCH_ENDPOINT

public static final String PROP_ELASTICSEARCH_ENDPOINT

See Also:

Constant Field Values

PROP_ELASTICSEARCH_PORT

public static final String PROP_ELASTICSEARCH_PORT

See Also:

Constant Field Values

PROP_ELASTICSEARCH_TRANSPORT_SNIFF

public static final String PROP_ELASTICSEARCH_TRANSPORT_SNIFF

See Also:

Constant Field Values

PROP_ELASTICSEARCH_IGNORE_CLUSTER_NAME

public static final String PROP_ELASTICSEARCH_IGNORE_CLUSTER_NAME

See Also:

Constant Field Values

PROP_ELASTICSEARCH_PING_TIMEOUT

public static final String PROP_ELASTICSEARCH_PING_TIMEOUT

See Also:

Constant Field Values

PROP_ELASTICSEARCH_NODE_SAMPLER_INTERVAL

public static final String PROP_ELASTICSEARCH_NODE_SAMPLER_INTERVAL

See Also:

Constant Field Values

PROP_ELASTICSEARCH_DEFAULT_INDEX_NAME

public static final String PROP_ELASTICSEARCH_DEFAULT_INDEX_NAME

See Also:

Constant Field Values

PROP_ELASTICSEARCH_DEFAULT_TYPE_NAME

public static final String PROP_ELASTICSEARCH_DEFAULT_TYPE_NAME

See Also:

Constant Field Values

PROP_ELASTICSEARCH_CLOUDFORMATION_TEMPLATE_URL

public static final String PROP_ELASTICSEARCH_CLOUDFORMATION_TEMPLATE_URL

See Also:

Constant Field Values

PROP_ELASTICSEARCH_CLOUDFORMATION_STACK_NAME

public static final String PROP_ELASTICSEARCH_CLOUDFORMATION_STACK_NAME

See Also:

Constant Field Values

PROP_ELASTICSEARCH_VERSION_NUMBER

public static final String PROP_ELASTICSEARCH_VERSION_NUMBER

See Also:

Constant Field Values

PROP_ELASTICSEARCH_CLOUDFORMATION_KEY_PAIR_NAME

public static final String PROP_ELASTICSEARCH_CLOUDFORMATION_KEY_PAIR_NAME

See Also:

Constant Field Values

PROP_ELASTICSEARCH_CLOUDFORMATION_CLUSTER_INSTANCE_TYPE

public static final String PROP_ELASTICSEARCH_CLOUDFORMATION_CLUSTER_INSTANCE_TYPE

See Also:

Constant Field Values

PROP_ELASTICSEARCH_CLOUDFORMATION_SSH_LOCATION

public static final String PROP_ELASTICSEARCH_CLOUDFORMATION_SSH_LOCATION

See Also:

Constant Field Values

PROP_ELASTICSEARCH_CLOUDFORMATION_CLUSTER_SIZE

public static final String PROP_ELASTICSEARCH_CLOUDFORMATION_CLUSTER_SIZE

See Also:

Constant Field Values

DEFAULT_APP_NAME

public static final String DEFAULT_APP_NAME

See Also:

Constant Field Values

DEFAULT_CONNECTOR_DESTINATION

public static final String DEFAULT_CONNECTOR_DESTINATION

See Also:

Constant Field Values

DEFAULT_RETRY_LIMIT

public static final int DEFAULT_RETRY_LIMIT

See Also:

Constant Field Values

DEFAULT_BACKOFF_INTERVAL

public static final long DEFAULT_BACKOFF_INTERVAL

See Also:

Constant Field Values

DEFAULT_BUFFER_RECORD_COUNT_LIMIT

public static final long DEFAULT_BUFFER_RECORD_COUNT_LIMIT

See Also:

Constant Field Values

DEFAULT_BUFFER_BYTE_SIZE_LIMIT

public static final long DEFAULT_BUFFER_BYTE_SIZE_LIMIT

See Also:

Constant Field Values

DEFAULT_BUFFER_MILLISECONDS_LIMIT

public static final long DEFAULT_BUFFER_MILLISECONDS_LIMIT

See Also:

Constant Field Values

DEFAULT_BATCH_RECORDS_IN_PUT_REQUEST

public static final boolean DEFAULT_BATCH_RECORDS_IN_PUT_REQUEST

See Also:

Constant Field Values

DEFAULT_KINESIS_ENDPOINT

public static final String DEFAULT_KINESIS_ENDPOINT

DEFAULT_KINESIS_INPUT_STREAM

public static final String DEFAULT_KINESIS_INPUT_STREAM

See Also:

Constant Field Values

DEFAULT_KINESIS_OUTPUT_STREAM

public static final String DEFAULT_KINESIS_OUTPUT_STREAM

See Also:

Constant Field Values

DEFAULT_KINESIS_STREAM_SHARD_COUNT

public static final int DEFAULT_KINESIS_STREAM_SHARD_COUNT

See Also:

Constant Field Values

DEFAULT_WORKER_ID

public static final String DEFAULT_WORKER_ID

DEFAULT_FAILOVER_TIME

public static final long DEFAULT_FAILOVER_TIME

See Also:

Constant Field Values

DEFAULT_MAX_RECORDS

public static final int DEFAULT_MAX_RECORDS

See Also:

Constant Field Values

DEFAULT_INITIAL_POSITION_IN_STREAM

public static final com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStream DEFAULT_INITIAL_POSITION_IN_STREAM

DEFAULT_IDLE_TIME_BETWEEN_READS

public static final long DEFAULT_IDLE_TIME_BETWEEN_READS

See Also:

Constant Field Values

DEFAULT_PARENT_SHARD_POLL_INTERVAL

public static final long DEFAULT_PARENT_SHARD_POLL_INTERVAL

See Also:

Constant Field Values

DEFAULT_SHARD_SYNC_INTERVAL

public static final long DEFAULT_SHARD_SYNC_INTERVAL

See Also:

Constant Field Values

DEFAULT_CALL_PROCESS_RECORDS_EVEN_FOR_EMPTY_LIST

public static final boolean DEFAULT_CALL_PROCESS_RECORDS_EVEN_FOR_EMPTY_LIST

See Also:

Constant Field Values

DEFAULT_CLEANUP_TERMINATED_SHARDS_BEFORE_EXPIRY

public static final boolean DEFAULT_CLEANUP_TERMINATED_SHARDS_BEFORE_EXPIRY

See Also:

Constant Field Values

DEFAULT_REGION_NAME

public static final String DEFAULT_REGION_NAME

See Also:

Constant Field Values

DEFAULT_S3_ENDPOINT

public static final String DEFAULT_S3_ENDPOINT

See Also:

Constant Field Values

DEFAULT_S3_BUCKET

public static final String DEFAULT_S3_BUCKET

See Also:

Constant Field Values

DEFAULT_REDSHIFT_ENDPOINT

public static final String DEFAULT_REDSHIFT_ENDPOINT

See Also:

Constant Field Values

DEFAULT_REDSHIFT_USERNAME

public static final String DEFAULT_REDSHIFT_USERNAME

DEFAULT_REDSHIFT_PASSWORD

public static final String DEFAULT_REDSHIFT_PASSWORD

DEFAULT_REDSHIFT_URL

public static final String DEFAULT_REDSHIFT_URL

DEFAULT_REDSHIFT_DATA_TABLE

public static final String DEFAULT_REDSHIFT_DATA_TABLE

See Also:

Constant Field Values

DEFAULT_REDSHIFT_FILE_TABLE

public static final String DEFAULT_REDSHIFT_FILE_TABLE

See Also:

Constant Field Values

DEFAULT_REDSHIFT_FILE_KEY_COLUMN

public static final String DEFAULT_REDSHIFT_FILE_KEY_COLUMN

See Also:

Constant Field Values

DEFAULT_REDSHIFT_DATA_DELIMITER

public static final Character DEFAULT_REDSHIFT_DATA_DELIMITER

DEFAULT_REDSHIFT_COPY_MANDATORY

public static final boolean DEFAULT_REDSHIFT_COPY_MANDATORY

See Also:

Constant Field Values

DEFAULT_DYNAMODB_ENDPOINT

public static final String DEFAULT_DYNAMODB_ENDPOINT

See Also:

Constant Field Values

DEFAULT_DYNAMODB_DATA_TABLE_NAME

public static final String DEFAULT_DYNAMODB_DATA_TABLE_NAME

See Also:

Constant Field Values

DEFAULT_CLOUDWATCH_NAMESPACE

public static final String DEFAULT_CLOUDWATCH_NAMESPACE

See Also:

Constant Field Values

DEFAULT_CLOUDWATCH_BUFFER_TIME

public static final long DEFAULT_CLOUDWATCH_BUFFER_TIME

See Also:

Constant Field Values

DEFAULT_CLOUDWATCH_MAX_QUEUE_SIZE

public static final int DEFAULT_CLOUDWATCH_MAX_QUEUE_SIZE

See Also:

Constant Field Values

DEFAULT_ELASTICSEARCH_CLUSTER_NAME

public static final String DEFAULT_ELASTICSEARCH_CLUSTER_NAME

See Also:

Constant Field Values

DEFAULT_ELASTICSEARCH_ENDPOINT

public static final String DEFAULT_ELASTICSEARCH_ENDPOINT

See Also:

Constant Field Values

DEFAULT_ELASTICSEARCH_PORT

public static final int DEFAULT_ELASTICSEARCH_PORT

See Also:

Constant Field Values

DEFAULT_ELASTICSEARCH_TRANSPORT_SNIFF

public static final boolean DEFAULT_ELASTICSEARCH_TRANSPORT_SNIFF

See Also:

Constant Field Values

DEFAULT_ELASTICSEARCH_IGNORE_CLUSTER_NAME

public static final boolean DEFAULT_ELASTICSEARCH_IGNORE_CLUSTER_NAME

See Also:

Constant Field Values

DEFAULT_ELASTICSEARCH_PING_TIMEOUT

public static final String DEFAULT_ELASTICSEARCH_PING_TIMEOUT

See Also:

Constant Field Values

DEFAULT_ELASTICSEARCH_NODE_SAMPLER_INTERVAL

public static final String DEFAULT_ELASTICSEARCH_NODE_SAMPLER_INTERVAL

See Also:

Constant Field Values

DEFAULT_ELASTICSEARCH_DEFAULT_INDEX_NAME

public static final String DEFAULT_ELASTICSEARCH_DEFAULT_INDEX_NAME

See Also:

Constant Field Values

DEFAULT_ELASTICSEARCH_DEFAULT_TYPE_NAME

public static final String DEFAULT_ELASTICSEARCH_DEFAULT_TYPE_NAME

See Also:

Constant Field Values

DEFAULT_ELASTICSEARCH_CLOUDFORMATION_TEMPLATE_URL

public static final String DEFAULT_ELASTICSEARCH_CLOUDFORMATION_TEMPLATE_URL

See Also:

Constant Field Values

DEFAULT_ELASTICSEARCH_CLOUDFORMATION_STACK_NAME

public static final String DEFAULT_ELASTICSEARCH_CLOUDFORMATION_STACK_NAME

See Also:

Constant Field Values

DEFAULT_ELASTICSEARCH_VERSION_NUMBER

public static final String DEFAULT_ELASTICSEARCH_VERSION_NUMBER

See Also:

Constant Field Values

DEFAULT_ELASTICSEARCH_CLOUDFORMATION_KEY_PAIR_NAME

public static final String DEFAULT_ELASTICSEARCH_CLOUDFORMATION_KEY_PAIR_NAME

See Also:

Constant Field Values

DEFAULT_ELASTICSEARCH_CLOUDFORMATION_CLUSTER_INSTANCE_TYPE

public static final String DEFAULT_ELASTICSEARCH_CLOUDFORMATION_CLUSTER_INSTANCE_TYPE

See Also:

Constant Field Values

DEFAULT_ELASTICSEARCH_CLOUDFORMATION_SSH_LOCATION

public static final String DEFAULT_ELASTICSEARCH_CLOUDFORMATION_SSH_LOCATION

See Also:

Constant Field Values

DEFAULT_ELASTICSEARCH_CLOUDFORMATION_CLUSTER_SIZE

public static final String DEFAULT_ELASTICSEARCH_CLOUDFORMATION_CLUSTER_SIZE

See Also:

Constant Field Values

AWS_CREDENTIALS_PROVIDER

public final com.amazonaws.auth.AWSCredentialsProvider AWS_CREDENTIALS_PROVIDER

APP_NAME

public final String APP_NAME

CONNECTOR_DESTINATION

public final String CONNECTOR_DESTINATION

BACKOFF_INTERVAL

public final long BACKOFF_INTERVAL

RETRY_LIMIT

public final int RETRY_LIMIT

BUFFER_RECORD_COUNT_LIMIT

public final long BUFFER_RECORD_COUNT_LIMIT

BUFFER_BYTE_SIZE_LIMIT

public final long BUFFER_BYTE_SIZE_LIMIT

BUFFER_MILLISECONDS_LIMIT

public final long BUFFER_MILLISECONDS_LIMIT

BATCH_RECORDS_IN_PUT_REQUEST

public final boolean BATCH_RECORDS_IN_PUT_REQUEST

KINESIS_ENDPOINT

public final String KINESIS_ENDPOINT

KINESIS_INPUT_STREAM

public final String KINESIS_INPUT_STREAM

KINESIS_INPUT_STREAM_SHARD_COUNT

public final int KINESIS_INPUT_STREAM_SHARD_COUNT

KINESIS_OUTPUT_STREAM

public final String KINESIS_OUTPUT_STREAM

KINESIS_OUTPUT_STREAM_SHARD_COUNT

public final int KINESIS_OUTPUT_STREAM_SHARD_COUNT

WORKER_ID

public final String WORKER_ID

FAILOVER_TIME

public final long FAILOVER_TIME

MAX_RECORDS

public final int MAX_RECORDS

INITIAL_POSITION_IN_STREAM

public final com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStream INITIAL_POSITION_IN_STREAM

IDLE_TIME_BETWEEN_READS

public final long IDLE_TIME_BETWEEN_READS

PARENT_SHARD_POLL_INTERVAL

public final long PARENT_SHARD_POLL_INTERVAL

SHARD_SYNC_INTERVAL

public final long SHARD_SYNC_INTERVAL

CALL_PROCESS_RECORDS_EVEN_FOR_EMPTY_LIST

public final boolean CALL_PROCESS_RECORDS_EVEN_FOR_EMPTY_LIST

CLEANUP_TERMINATED_SHARDS_BEFORE_EXPIRY

public final boolean CLEANUP_TERMINATED_SHARDS_BEFORE_EXPIRY

REGION_NAME

public final String REGION_NAME

S3_ENDPOINT

public final String S3_ENDPOINT

S3_BUCKET

public final String S3_BUCKET

REDSHIFT_ENDPOINT

public final String REDSHIFT_ENDPOINT

REDSHIFT_USERNAME

public final String REDSHIFT_USERNAME

REDSHIFT_PASSWORD

public final String REDSHIFT_PASSWORD

REDSHIFT_URL

public String REDSHIFT_URL

REDSHIFT_DATA_TABLE

public final String REDSHIFT_DATA_TABLE

REDSHIFT_FILE_TABLE

public final String REDSHIFT_FILE_TABLE

REDSHIFT_FILE_KEY_COLUMN

public final String REDSHIFT_FILE_KEY_COLUMN

REDSHIFT_DATA_DELIMITER

public final Character REDSHIFT_DATA_DELIMITER

REDSHIFT_COPY_MANDATORY

public final boolean REDSHIFT_COPY_MANDATORY

DYNAMODB_ENDPOINT

public final String DYNAMODB_ENDPOINT

DYNAMODB_DATA_TABLE_NAME

public final String DYNAMODB_DATA_TABLE_NAME

CLOUDWATCH_NAMESPACE

public final String CLOUDWATCH_NAMESPACE

CLOUDWATCH_BUFFER_TIME

public final long CLOUDWATCH_BUFFER_TIME

CLOUDWATCH_MAX_QUEUE_SIZE

public final int CLOUDWATCH_MAX_QUEUE_SIZE

ELASTICSEARCH_CLUSTER_NAME

public final String ELASTICSEARCH_CLUSTER_NAME

ELASTICSEARCH_ENDPOINT

public String ELASTICSEARCH_ENDPOINT

ELASTICSEARCH_PORT

public final int ELASTICSEARCH_PORT

ELASTICSEARCH_TRANSPORT_SNIFF

public final boolean ELASTICSEARCH_TRANSPORT_SNIFF

ELASTICSEARCH_IGNORE_CLUSTER_NAME

public final boolean ELASTICSEARCH_IGNORE_CLUSTER_NAME

ELASTICSEARCH_PING_TIMEOUT

public final String ELASTICSEARCH_PING_TIMEOUT

ELASTICSEARCH_NODE_SAMPLER_INTERVAL

public final String ELASTICSEARCH_NODE_SAMPLER_INTERVAL

ELASTICSEARCH_DEFAULT_INDEX_NAME

public final String ELASTICSEARCH_DEFAULT_INDEX_NAME

ELASTICSEARCH_DEFAULT_TYPE_NAME

public final String ELASTICSEARCH_DEFAULT_TYPE_NAME

ELASTICSEARCH_CLOUDFORMATION_TEMPLATE_URL

public final String ELASTICSEARCH_CLOUDFORMATION_TEMPLATE_URL

ELASTICSEARCH_CLOUDFORMATION_STACK_NAME

public final String ELASTICSEARCH_CLOUDFORMATION_STACK_NAME

ELASTICSEARCH_VERSION_NUMBER

public final String ELASTICSEARCH_VERSION_NUMBER

ELASTICSEARCH_CLOUDFORMATION_KEY_PAIR_NAME

public final String ELASTICSEARCH_CLOUDFORMATION_KEY_PAIR_NAME

ELASTICSEARCH_CLOUDFORMATION_CLUSTER_INSTANCE_TYPE

public final String ELASTICSEARCH_CLOUDFORMATION_CLUSTER_INSTANCE_TYPE

ELASTICSEARCH_CLOUDFORMATION_SSH_LOCATION

public final String ELASTICSEARCH_CLOUDFORMATION_SSH_LOCATION

ELASTICSEARCH_CLOUDFORMATION_CLUSTER_SIZE

public final String ELASTICSEARCH_CLOUDFORMATION_CLUSTER_SIZE

Constructor Detail

KinesisConnectorConfiguration

public KinesisConnectorConfiguration(Properties properties,
                                     com.amazonaws.auth.AWSCredentialsProvider credentialsProvider)

Configure the connector application with any set of properties that are unique to the application. Any unspecified property will be set to a default value.

Parameters:

properties - the System properties that will be used to configure KinesisConnectors