From c586159bd378b2147ab4e93092badda1c90ce940 Mon Sep 17 00:00:00 2001
From: Karthik Puttaswamy <karthikx@amazon.com>
Date: Fri, 6 Jun 2025 17:25:40 -0700
Subject: [PATCH] Adding Key/Value Schema metadata attributes for KafkaEvent

---
 .../services/lambda/runtime/events/KafkaEvent.java    | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/KafkaEvent.java b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/KafkaEvent.java
index dd051d48..aa6c00de 100644
--- a/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/KafkaEvent.java
+++ b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/KafkaEvent.java
@@ -43,6 +43,8 @@ public static class KafkaEventRecord {
         private String key;
         private String value;
         private List<Map<String, byte[]>> headers;
+        private SchemaMetadata keySchemaMetadata;
+        private SchemaMetadata valueSchemaMetadata;
     }
 
     @Data
@@ -59,4 +61,13 @@ public String toString() {
             return topic + "-" + partition;
         }
     }
+
+    @Data
+    @AllArgsConstructor
+    @NoArgsConstructor
+    @Builder(setterPrefix = "with")
+    public static class SchemaMetadata {
+        private String schemaId;
+        private String dataFormat;
+    }
 }