From 1409658a1046e77b2024726317e3048ada230a4a Mon Sep 17 00:00:00 2001 From: Eric Meisel Date: Fri, 24 Mar 2023 13:16:47 -0500 Subject: [PATCH] Add simple SingleStreamTracker constructor with position --- .../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 703c4881c..fd1e045c8 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 SingleStreamTracker( 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);