| Interface | Description |
|---|---|
| KinesisConsumer.Factory | |
| KinesisRecordProcessor.Factory |
| Class | Description |
|---|---|
| GlobalKinesisConfiguration |
Class representing the Global Kinesis configuration
|
| KinesisConsumer |
Responsible to connect to the configured Kinesis streams and start the scheduler threads to begin
polling records
|
| KinesisConsumerManager |
Manager of stream connections
|
| KinesisConsumerModule | |
| KinesisRecordProcessor |
Implements the
ShardRecordProcessor interface to process data records fetched from Amazon
Kinesis |
| KinesisRecordProcessorFactory |
Factory to create
KinesisRecordProcessor instances. |
| KinesisStreamItem |
Class representing a Stream configuration
|
| KinesisStreamItem.DescriptorImpl | |
| SaveableListenerImpl |
Extends
SaveableListener to listen to GlobalKinesisConfiguration changes. |
Copyright © 2016–2021. All rights reserved.