Class 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
    • 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