Modifier and Type | Method and Description |
---|---|
static StartingPosition |
continueFromSequenceNumber(SequenceNumber sequenceNumber)
Returns the starting position for the next record to consume from the given sequence number.
|
static StartingPosition |
fromTimestamp(Date date) |
com.amazonaws.services.kinesis.model.ShardIteratorType |
getShardIteratorType() |
Object |
getStartingMarker() |
static StartingPosition |
restartFromSequenceNumber(SequenceNumber sequenceNumber)
Returns the starting position to restart record consumption from the given sequence number
after failure.
|
public com.amazonaws.services.kinesis.model.ShardIteratorType getShardIteratorType()
public static StartingPosition fromTimestamp(Date date)
public static StartingPosition continueFromSequenceNumber(SequenceNumber sequenceNumber)
restartFromSequenceNumber()
and continueFromSequenceNumber()
is that for restartFromSequenceNumber()
aggregated
records are reread to support subsequence failure.sequenceNumber
- the last successful sequence number, or sentinel markerpublic static StartingPosition restartFromSequenceNumber(SequenceNumber sequenceNumber)
restartFromSequenceNumber()
and continueFromSequenceNumber()
is that for restartFromSequenceNumber()
aggregated
records are reread to support subsequence failure.sequenceNumber
- the last successful sequence number, or sentinel markerCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.