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;
+    }
 }