From 88246e717e82dd9d877d3287de445b7fc73b06c4 Mon Sep 17 00:00:00 2001 From: Eric Meisel Date: Sun, 26 Mar 2023 08:24:22 -0500 Subject: [PATCH] Add simple SingleStreamTracker constructor with position (#1086) --- .../amazon/kinesis/processor/SingleStreamTracker.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/processor/SingleStreamTracker.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/processor/SingleStreamTracker.java index 703c4881..fd1e045c 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/processor/SingleStreamTracker.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/processor/SingleStreamTracker.java @@ -58,6 +58,12 @@ public class SingleStreamTracker implements StreamTracker { this(streamIdentifier, new StreamConfig(streamIdentifier, initialPosition)); } + public SingleStreamTracker( + String streamName, + @NonNull InitialPositionInStreamExtended initialPosition) { + this(StreamIdentifier.singleStreamInstance(streamName), initialPosition); + } + public SingleStreamTracker(@NonNull StreamIdentifier streamIdentifier, @NonNull StreamConfig streamConfig) { this.streamIdentifier = streamIdentifier; this.streamConfigs = Collections.singletonList(streamConfig);