Package io.awspring.cloud.kinesis.integration

package io.awspring.cloud.kinesis.integration

Class	Description
Checkpointer	A callback for target record process to perform checkpoint on the related shard.
CheckpointMode	The listener mode, record or batch.
KclMessageDrivenChannelAdapter	The MessageProducerSupport implementation for receiving data from Amazon Kinesis stream(s) using AWS KCL.
KinesisHeaders	Constants for Kinesis message headers.
KinesisMessageDrivenChannelAdapter	The MessageProducerSupport implementation for receiving data from Amazon Kinesis stream(s).
KinesisMessageHandler	The AbstractMessageHandler implementation for the Amazon Kinesis putRecord(s).
KinesisMessageHeaderErrorMessageStrategy	The ErrorMessageStrategy implementation to build an ErrorMessage with the KinesisHeaders.RAW_RECORD header as the value from the provided AttributeAccessor.
KinesisShardEndedEvent	An event emitted when shard is closed for consumption.
KinesisShardOffset	A model to represent a sequence in the shard for particular ShardIteratorType.
KplBackpressureException	An exception triggered from the KplMessageHandler while sending records to Kinesis when maximum number of records in flight exceeds the backpressure threshold.
KplMessageHandler	The AbstractMessageHandler implementation for the Amazon Kinesis Producer Library putRecord(s).
ListenerMode	The listener mode, record or batch.
SpringDynamoDBStreamsAdapterClient	This is Spring Cloud DynamoDB Adapter to be able to support ListShards operations.