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.

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

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

DefaultEnableLeaseStealing Lease stealing defaults to false for backwards compatibility.

DefaultFailoverTimeMillis Fail over time in milliseconds.

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

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

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

DefaultInitialPositionInStream 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.

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

DefaultLeaseRefreshWaitTime is the period of time to wait before async lease renewal attempt.

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

DefaultLeaseStealingIntervalMillis Interval between rebalance tasks defaults to 5 seconds.

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

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

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

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

DefaultMaxRetryCount The default maximum number of retries in case of error.

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

DefaultShardSyncIntervalMillis Shard sync interval in milliseconds - e.g.

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

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

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

DefaultValidateSequenceNumberBeforeCheckpointing 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.