See: Description
| Interface | Description |
|---|---|
| Checkpointer |
A callback for target record process to perform checkpoint on the related shard.
|
| Class | Description |
|---|---|
| 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.
|