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);