Update MSKFirehoseEventHandler.java

Changed naming conventions.

Author: ShashankAWS

samples/msk-firehose-event-handler/src/main/java/example/MSKFirehoseEventHandler.java

@@ -2,8 +2,8 @@
 
 import com.amazonaws.services.lambda.runtime.Context;
 import com.amazonaws.services.lambda.runtime.RequestHandler;
-import com.amazonaws.services.lambda.runtime.events.MSKFirehoseResponse;
-import com.amazonaws.services.lambda.runtime.events.MSKFirehoseEvent;
+import model.MSKFirehoseResponse;
+import events.MSKFirehoseEvent;
 import org.json.JSONObject;
 
 import java.nio.ByteBuffer;
@@ -14,13 +14,13 @@
  * A sample MSKFirehoseEvent handler
  * For more information see the developer guide - <a href="https://docs.aws.amazon.com/firehose/latest/dev/data-transformation.html">...</a>
  */
-public class MSKFirehoseEventHandler implements RequestHandler<MSKFirehoseEvent, MSKFirehoseResponse> {
+public class Sample implements RequestHandler<MSKFirehoseEvent, MSKFirehoseResponse> {
 
     @Override
-    public MSKFirehoseResponse handleRequest(MSKFirehoseEvent kinesisFirehoseEvent, Context context) {
+    public MSKFirehoseResponse handleRequest(MSKFirehoseEvent MSKFirehoseEvent, Context context) {
         List<MSKFirehoseResponse.Record> records = new ArrayList<>();
 
-        for (MSKFirehoseEvent.Record record : kinesisFirehoseEvent.getRecords()) {
+        for (MSKFirehoseEvent.Record record : MSKFirehoseEvent.getRecords()) {
             String recordData = new String(record.getKafkaRecordValue().array());
             // Your business logic
             JSONObject jsonObject = new JSONObject(recordData);