Package software.amazon.kinesis.lifecycle

Interface Summary

Interface	Description
ConsumerTask	Interface for shard processing tasks.
ConsumerTaskFactory
NotifyingSubscriber	Subscriber that notifies its publisher on receipt of the onNext event.
ShutdownNotification	A shutdown request to the ShardConsumer
TaskExecutionListener	A listener for callbacks on task execution lifecycle for for a shard.

Class Summary

Class	Description
BlockOnParentShardTask	Task to block until processing of all data records in the parent shard(s) is completed.
InitializeTask	Task for initializing shard position and invoking the ShardRecordProcessor initialize() API.
KinesisConsumerTaskFactory
LeaseGracefulShutdownHandler	This class handles the graceful shutdown of shard consumers.
LifecycleConfig	Used by the KCL to configure the lifecycle.
NoOpTaskExecutionListener	NoOp implementation of TaskExecutionListener interface that takes no action on task execution.
ProcessTask	Task for fetching data records and invoking processRecords() on the record processor instance.
ShardConsumer	Responsible for consuming data records of a (specified) shard.
ShardConsumerArgument
ShardConsumerNotifyingSubscriber
ShardConsumerShutdownNotification	Contains callbacks for completion of stages in a requested record processor shutdown.
ShutdownInput	Container for the parameters to the IRecordProcessor's shutdown method.
ShutdownNotificationTask	Notifies record processor of incoming shutdown request, and gives them a chance to checkpoint.
ShutdownTask	Task for invoking the ShardRecordProcessor shutdown() callback.
TaskResult	Used to capture information from a task that we want to communicate back to the higher layer.

Enum Summary

Enum	Description
ShutdownReason	Reason the ShardRecordProcessor is being shutdown.
TaskOutcome	Enumerates types of outcome of tasks executed as part of processing a shard.
TaskType	Enumerates types of tasks executed as part of processing a shard.