@Internal public class FanOutRecordPublisher extends Object implements RecordPublisher
RecordPublisherthat will read and forward records from Kinesis using EFO, to the subscriber. Records are consumed via Enhanced Fan Out subscriptions using SubscribeToShard API.
|Constructor and Description|
Instantiate a new FanOutRecordPublisher.
|Modifier and Type||Method and Description|
Run the record publisher.
public FanOutRecordPublisher(StartingPosition startingPosition, String consumerArn, StreamShardHandle subscribedShard, KinesisProxyV2Interface kinesisProxy, FanOutRecordPublisherConfiguration configuration, FullJitterBackoff backoff)
startingPosition- the position in the shard to start consuming from
consumerArn- the consumer ARN of the stream consumer
subscribedShard- the shard to consumer from
kinesisProxy- the proxy used to talk to Kinesis services
configuration- the record publisher configuration
public RecordPublisher.RecordPublisherRunResult run(RecordPublisher.RecordBatchConsumer recordConsumer) throws InterruptedException
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.