luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Add simple SingleStreamTracker constructor with position (#1086)

Browse source
This commit is contained in:
Eric Meisel 2023-03-26 08:24:22 -05:00 committed by GitHub
parent b8d3390bf3
commit 88246e717e
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
amazon-kinesis-client/src/main/java/software/amazon/kinesis/processor/SingleStreamTracker.java
View file

@ -58,6 +58,12 @@ public class SingleStreamTracker implements StreamTracker {
this(streamIdentifier, new StreamConfig(streamIdentifier, initialPosition)); 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) { public SingleStreamTracker(@NonNull StreamIdentifier streamIdentifier, @NonNull StreamConfig streamConfig) {
this.streamIdentifier = streamIdentifier; this.streamIdentifier = streamIdentifier;
this.streamConfigs = Collections.singletonList(streamConfig); this.streamConfigs = Collections.singletonList(streamConfig);