KinesisRecordProcessor (AWS Kinesis Consumer Plugin 1.0.5 API)

java.lang.Object
- io.jenkins.plugins.aws.kinesisconsumer.KinesisRecordProcessor

All Implemented Interfaces:

software.amazon.kinesis.processor.ShardRecordProcessor
```
public class KinesisRecordProcessor
extends Object
implements software.amazon.kinesis.processor.ShardRecordProcessor
```
Implements the ShardRecordProcessor interface to process data records fetched from Amazon Kinesis

Author:

Fabio Ponciroli

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static interface KinesisRecordProcessor.Factory

Field Summary

Fields
Modifier and Type Field Description

String streamName

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`initialize(software.amazon.kinesis.lifecycle.events.InitializationInput initializationInput)`
`void`	`leaseLost(software.amazon.kinesis.lifecycle.events.LeaseLostInput leaseLostInput)`
`void`	`processRecords(software.amazon.kinesis.lifecycle.events.ProcessRecordsInput processRecordsInput)`	Forward each byte record of `ProcessRecordsInput` to the `AWSKinesisStreamListener` interface
`void`	`shardEnded(software.amazon.kinesis.lifecycle.events.ShardEndedInput shardEndedInput)`
`void`	`shutdownRequested(software.amazon.kinesis.lifecycle.events.ShutdownRequestedInput shutdownRequestedInput)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - streamName
```
public final String streamName
```
- Method Detail
  - initialize
```
public void initialize(software.amazon.kinesis.lifecycle.events.InitializationInput initializationInput)
```
    Specified by:
    
    initialize in interface software.amazon.kinesis.processor.ShardRecordProcessor
  - processRecords
```
public void processRecords(software.amazon.kinesis.lifecycle.events.ProcessRecordsInput processRecordsInput)
```
    Forward each byte record of ProcessRecordsInput to the AWSKinesisStreamListener interface
    
    Specified by:
    
    processRecords in interface software.amazon.kinesis.processor.ShardRecordProcessor
    
    Parameters:
    
    processRecordsInput - ProcessRecordsInput to process
  - leaseLost
```
public void leaseLost(software.amazon.kinesis.lifecycle.events.LeaseLostInput leaseLostInput)
```
    Specified by:
    
    leaseLost in interface software.amazon.kinesis.processor.ShardRecordProcessor
  - shardEnded
```
public void shardEnded(software.amazon.kinesis.lifecycle.events.ShardEndedInput shardEndedInput)
```
    Specified by:
    
    shardEnded in interface software.amazon.kinesis.processor.ShardRecordProcessor
  - shutdownRequested
```
public void shutdownRequested(software.amazon.kinesis.lifecycle.events.ShutdownRequestedInput shutdownRequestedInput)
```
    Specified by:
    
    shutdownRequested in interface software.amazon.kinesis.processor.ShardRecordProcessor