diff --git a/integration-sns-to-lambda/example.js b/integration-sns-to-lambda/example.js
deleted file mode 100644
index 06e5734..0000000
--- a/integration-sns-to-lambda/example.js
+++ /dev/null
@@ -1,19 +0,0 @@
-// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
-// SPDX-License-Identifier: Apache-2.0
-exports.handler = async (event, context) => {
-  for (const record of event.Records) {
-    await processMessageAsync(record);
-  }
-  console.info("done");
-};
-
-async function processMessageAsync(record) {
-  try {
-    const message = JSON.stringify(record.Sns.Message);
-    console.log(`Processed message ${message}`);
-    await Promise.resolve(1); //Placeholder for actual async work
-  } catch (err) {
-    console.error("An error occurred");
-    throw err;
-  }
-}
diff --git a/integration-sns-to-lambda/example.mjs b/integration-sns-to-lambda/example.mjs
new file mode 100644
index 0000000..4674d3a
--- /dev/null
+++ b/integration-sns-to-lambda/example.mjs
@@ -0,0 +1,21 @@
+// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: Apache-2.0
+export const handler = async (event, context) => {
+    for (const record of event.Records) {
+      await processMessageAsync(record);
+    }
+    console.info("done");
+  };
+  
+  async function processMessageAsync(record) {
+    try {
+      const message = JSON.stringify(record.Sns.Message);
+      console.log(`Processed message ${message}`);
+      await Promise.resolve(1); //Placeholder for actual async work
+    } catch (err) {
+      console.error("An error occurred");
+      throw err;
+    }
+  }
+  
+  
\ No newline at end of file
diff --git a/lambda-function-sqs-report-batch-item-failures/example.py b/lambda-function-sqs-report-batch-item-failures/example.py
index cdd8c27..f8f3ccc 100644
--- a/lambda-function-sqs-report-batch-item-failures/example.py
+++ b/lambda-function-sqs-report-batch-item-failures/example.py
@@ -8,7 +8,7 @@ def lambda_handler(event, context):
      
         for record in event["Records"]:
             try:
-                # process message
+                print(f"Processed message: {record['body']}")
             except Exception as e:
                 batch_item_failures.append({"itemIdentifier": record['messageId']})