public static Void processRecords(List<KinesisEventRecord> inputRecords,KinesisUserRecordProcessor processor){
  List<Record> rawRecords=new LinkedList<>();
  for (  KinesisEventRecord rec : inputRecords) {
    rawRecords.add(rec.getKinesis());
  }
  return processor.process(UserRecord.deaggregate(rawRecords));
}

public static Void processRecords ( List < KinesisEventRecord > inputRecords , KinesisUserRecordProcessor processor ) { List < Record > rawRecords = new LinkedList < > ( ) ; for ( KinesisEventRecord rec : inputRecords ) { rawRecords . add ( rec . getKinesis ( ) ) ; } return processor . process ( UserRecord . deaggregate ( rawRecords ) ) ; }
method to process a set of kinesis user records from a list of kinesis event records using pre - streams style api
