@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.RecordPublisher.RecordBatchConsumer, RecordPublisher.RecordPublisherRunResult
Modifier and Type | Method and Description |
---|---|
RecordPublisher.RecordPublisherRunResult |
run(RecordPublisher.RecordBatchConsumer consumer)
Run the record publisher.
|
run
public RecordPublisher.RecordPublisherRunResult run(RecordPublisher.RecordBatchConsumer consumer) throws InterruptedException
RecordPublisher
run
in interface RecordPublisher
run
in class PollingRecordPublisher
consumer
- the record batch consumer in which to output recordsInterruptedException
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.