Uses of Class
io.awspring.cloud.kinesis.integration.KinesisShardOffset
Packages that use KinesisShardOffset
-
Uses of KinesisShardOffset in io.awspring.cloud.kinesis.integration
Methods in io.awspring.cloud.kinesis.integration that return KinesisShardOffsetModifier and TypeMethodDescriptionstatic KinesisShardOffsetKinesisShardOffset.afterSequenceNumber(String sequenceNumber) static KinesisShardOffsetKinesisShardOffset.afterSequenceNumber(String stream, String shard, String sequenceNumber) static KinesisShardOffsetKinesisShardOffset.atSequenceNumber(String sequenceNumber) static KinesisShardOffsetKinesisShardOffset.atSequenceNumber(String stream, String shard, String sequenceNumber) static KinesisShardOffsetKinesisShardOffset.atTimestamp(String stream, String shard, Instant timestamp) static KinesisShardOffsetKinesisShardOffset.atTimestamp(Instant timestamp) static KinesisShardOffsetKinesisShardOffset.latest()static KinesisShardOffsetKinesisShardOffset.reset()static KinesisShardOffsetKinesisShardOffset.trimHorizon()static KinesisShardOffsetKinesisShardOffset.trimHorizon(String stream, String shard) Methods in io.awspring.cloud.kinesis.integration with parameters of type KinesisShardOffsetModifier and TypeMethodDescriptionvoidKinesisMessageDrivenChannelAdapter.setStreamInitialSequence(KinesisShardOffset streamInitialSequence) Constructors in io.awspring.cloud.kinesis.integration with parameters of type KinesisShardOffsetModifierConstructorDescriptionKinesisMessageDrivenChannelAdapter(software.amazon.awssdk.services.kinesis.KinesisAsyncClient amazonKinesis, KinesisShardOffset... shardOffsets)