See: Description
| Interface | Description |
|---|---|
| Checkpointer |
A callback for target record process to perform checkpoint on the related shard.
|
| Class | Description |
|---|---|
| KclMessageDrivenChannelAdapter |
The
MessageProducerSupport implementation for receiving data from Amazon
Kinesis stream(s) using AWS KCL. |
| KinesisMessageDrivenChannelAdapter |
The
MessageProducerSupport implementation for receiving data from Amazon Kinesis
stream(s). |
| KinesisMessageHeaderErrorMessageStrategy |
The
ErrorMessageStrategy implementation to build an ErrorMessage with
the AwsHeaders.RAW_RECORD header by the value from the the provided
AttributeAccessor. |
| KinesisShardOffset |
A model to represent a sequence in the shard for particular
ShardIteratorType. |
| Enum | Description |
|---|---|
| CheckpointMode |
The listener mode, record or batch.
|
| ListenerMode |
The listener mode, record or batch.
|