@Internal public class AdaptivePollingRecordPublisher extends PollingRecordPublisher
PollingRecordPublisher. Kinesis Streams have quotas on the transactions per second, and throughout. This class attempts to balance quotas and mitigate back off errors.
|Modifier and Type||Method and Description|
Run the record publisher.
public RecordPublisher.RecordPublisherRunResult run(RecordPublisher.RecordBatchConsumer consumer) throws InterruptedException
consumer- the record batch consumer in which to output records
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.