Class | Description |
---|---|
AdaptivePollingRecordPublisher |
An adaptive record publisher to add a dynamic batch read size for
PollingRecordPublisher . |
PollingRecordPublisher |
A
RecordPublisher that will read records from Kinesis and forward them to the subscriber. |
PollingRecordPublisherConfiguration |
A configuration class for
PollingRecordPublisher instantiated from a properties map. |
PollingRecordPublisherFactory |
A
RecordPublisher factory used to create instances of PollingRecordPublisher . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.