NewKinesisClientLibConfig creates a default KinesisClientLibConfiguration based on the required fields.

NewKinesisClientLibConfigWithCredential creates a default KinesisClientLibConfiguration based on the required fields and unique credentials.

NewKinesisClientLibConfigWithCredentials creates a default KinesisClientLibConfiguration based on the required fields and specific credentials for each service.

AT_TIMESTAMP start from the record at or after the specified server-side Timestamp.

Cleanup leases upon shards completion (don't wait until they expire in Kinesis).

Don't call processRecords() on the record processor for empty record lists.

Lease stealing defaults to false for backwards compatibility.

Fail over time in milliseconds.

The default value for how long the {@link ShardConsumer} should sleep if no records are returned from the call to.

The Amazon DynamoDB table used for tracking leases will be provisioned with this read capacity.

The Amazon DynamoDB table used for tracking leases will be provisioned with this write capacity.

The location in the shard from which the KinesisClientLibrary will start fetching records from when the application starts for the first time and there is no checkpoint for the shard.

Period before the end of lease during which a lease is refreshed by the owner.

Number of milliseconds to wait before another worker can aquire a claimed shard.

Interval between rebalance tasks defaults to 5 seconds.

Number of milliseconds to wait before syncing with lease table (dynamodDB).

The max number of leases (shards) this worker should process.

Max leases to steal from another worker at one time (for load balancing).

Max records to fetch from Kinesis in a single GetRecords call.

Interval in milliseconds between polling to check for parent shard completion.

Shard sync interval in milliseconds - e.g.

The amount of milliseconds to wait before graceful shutdown forcefully terminates.

The Worker will skip shard sync during initialization if there are one or more leases in the lease table.

Backoff time in milliseconds for Amazon Kinesis Client Library tasks (in the event of failures).

KCL will validate client provided sequence numbers with a call to Amazon Kinesis before checkpointing for calls to {@link RecordProcessorCheckpointer#checkpoint(String)} by default.

LATEST start after the most recent data record (fetch new data).

TRIM_HORIZON start from the oldest available data record.