Class KinesisRecordProcessor

  • All Implemented Interfaces:

    public class KinesisRecordProcessor
    extends Object
    Implements the ShardRecordProcessor interface to process data records fetched from Amazon Kinesis
    Fabio Ponciroli
    • Field Detail

      • streamName

        public final String streamName
    • Method Detail

      • initialize

        public void initialize​( initializationInput)
        Specified by:
        initialize in interface
      • processRecords

        public void processRecords​( processRecordsInput)
        Forward each byte record of ProcessRecordsInput to the AWSKinesisStreamListener interface
        Specified by:
        processRecords in interface
        processRecordsInput - ProcessRecordsInput to process
      • leaseLost

        public void leaseLost​( leaseLostInput)
        Specified by:
        leaseLost in interface
      • shardEnded

        public void shardEnded​( shardEndedInput)
        Specified by:
        shardEnded in interface
      • shutdownRequested

        public void shutdownRequested​( shutdownRequestedInput)
        Specified by:
        shutdownRequested in interface