Package io.jenkins.plugins.aws.kinesisconsumer
-
Interface Summary Interface Description KinesisConsumer.Factory KinesisRecordProcessor.Factory -
Class Summary Class Description GlobalKinesisConfiguration Class representing the Global Kinesis configurationKinesisConsumer Responsible to connect to the configured Kinesis streams and start the scheduler threads to begin polling recordsKinesisConsumerManager Manager of stream connectionsKinesisConsumerModule KinesisRecordProcessor Implements theShardRecordProcessorinterface to process data records fetched from Amazon KinesisKinesisRecordProcessorFactory Factory to createKinesisRecordProcessorinstances.KinesisStreamItem Class representing a Stream configurationKinesisStreamItem.DescriptorImpl SaveableListenerImpl ExtendsSaveableListenerto listen toGlobalKinesisConfigurationchanges.