package com.amazonaws.kafka.samples; import com.amazonaws.services.lambda.runtime.Context; import com.amazonaws.services.lambda.runtime.RequestHandler; import com.amazonaws.services.lambda.runtime.events.KafkaEvent; import com.google.gson.Gson; import com.google.gson.GsonBuilder; public class HandlerMSK implements RequestHandler<KafkaEvent, String> { private static final Gson gson = new GsonBuilder().setPrettyPrinting().create(); @Override public String handleRequest(KafkaEvent kafkaEvent, Context context) { String response = "200 OK"; Util.logEnvironment(kafkaEvent, context, gson); new ProcessRecords().processRecords(kafkaEvent, context.getAwsRequestId()); return response; } }