import com.amazonaws.kinesis.deagg.RecordDeaggregator;

import com.amazonaws.services.lambda.runtime.Context;

import com.amazonaws.services.lambda.runtime.LambdaLogger;

import com.amazonaws.services.lambda.runtime.RequestHandler;

import com.amazonaws.services.lambda.runtime.events.KinesisEvent;



public class KinesisConsumer implements RequestHandler<KinesisEvent, Void> {

   

   public Void handleRequest(KinesisEvent event, Context context) {

      System.out.println("Received " + event.getRecords().size() + " Event Records.");

      

      RecordDeaggregator.stream(event.getRecords().stream(), userRecord -> {

         String message = new String(userRecord.getData().array());

         System.out.println(message);

      });



      return null;

   }

}