Package org.springframework.integration.aws.inbound.kinesis
package org.springframework.integration.aws.inbound.kinesis
Provides components for AWS Kinesis.
-
ClassDescriptionA callback for target record process to perform checkpoint on the related shard.The listener mode, record or batch.The
MessageProducerSupport
implementation for receiving data from Amazon Kinesis stream(s) using AWS KCL.TheMessageProducerSupport
implementation for receiving data from Amazon Kinesis stream(s).TheErrorMessageStrategy
implementation to build anErrorMessage
with theAwsHeaders.RAW_RECORD
header by the value from the the providedAttributeAccessor
.A model to represent a sequence in the shard for particularShardIteratorType
.The listener mode, record or batch.