Add headers in KafkaEventRecord

Peiyu Wu · Peiyu Wu · commit af088f77fb25 · 2021-07-21T23:00:45.000-07:00
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
@@ -42,6 +42,7 @@ public static class KafkaEventRecord {
         private String timestampType;
         private String key;
         private String value;
+        private List<Map<String, byte[]>> headers;
     }
 
     @Data

Original file line number	Diff line number	Diff line change
`@@ -42,6 +42,7 @@ public static class KafkaEventRecord {`
`42`	`42`	`private String timestampType;`
`43`	`43`	`private String key;`
`44`	`44`	`private String value;`
	`45`	`+ private List<Map<String, byte[]>> headers;`
`45`	`46`	`}`
`46`	`47`
`47`	`48`	`@Data`