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