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
MessageProducerSupportimplementation for receiving data from Amazon Kinesis stream(s) using AWS KCL.TheMessageProducerSupportimplementation for receiving data from Amazon Kinesis stream(s).TheErrorMessageStrategyimplementation to build anErrorMessagewith theAwsHeaders.RAW_RECORDheader by the value from the the providedAttributeAccessor.A model to represent a sequence in the shard for particularShardIteratorType.The listener mode, record or batch.