Modifier and Type | Method and Description |
---|---|
RecordPublisher |
RecordPublisherFactory.create(StartingPosition startingPosition,
Properties consumerConfig,
MetricGroup metricGroup,
StreamShardHandle streamShardHandle)
Create a
RecordPublisher . |
Modifier and Type | Method and Description |
---|---|
FanOutRecordPublisher |
FanOutRecordPublisherFactory.create(StartingPosition startingPosition,
Properties consumerConfig,
MetricGroup metricGroup,
StreamShardHandle streamShardHandle)
Create a
FanOutRecordPublisher . |
Constructor and Description |
---|
FanOutRecordPublisher(StartingPosition startingPosition,
String consumerArn,
StreamShardHandle subscribedShard,
KinesisProxyV2Interface kinesisProxy,
FanOutRecordPublisherConfiguration configuration,
FullJitterBackoff backoff,
java.util.function.Supplier<Boolean> runningSupplier)
Instantiate a new FanOutRecordPublisher.
|
Modifier and Type | Method and Description |
---|---|
PollingRecordPublisher |
PollingRecordPublisherFactory.create(StartingPosition startingPosition,
Properties consumerConfig,
MetricGroup metricGroup,
StreamShardHandle streamShardHandle)
Create a
PollingRecordPublisher . |
Modifier and Type | Method and Description |
---|---|
static StartingPosition |
StartingPosition.continueFromSequenceNumber(SequenceNumber sequenceNumber)
Returns the starting position for the next record to consume from the given sequence number.
|
static StartingPosition |
StartingPosition.fromTimestamp(Date date) |
static StartingPosition |
StartingPosition.restartFromSequenceNumber(SequenceNumber sequenceNumber)
Returns the starting position to restart record consumption from the given sequence number
after failure.
|
Modifier and Type | Method and Description |
---|---|
static StartingPosition |
AWSUtil.getStartingPosition(SequenceNumber sequenceNumber,
Properties configProps)
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.