Skip to content

Commit f001ae7

Browse files
karthikpswamyKarthik Puttaswamy
andauthored
Adding Key/Value Schema metadata attributes for KafkaEvent (#548)
Co-authored-by: Karthik Puttaswamy <[email protected]>
1 parent 5a0f8ad commit f001ae7

File tree

1 file changed

+11
-0
lines changed
  • aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events

1 file changed

+11
-0
lines changed

aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/KafkaEvent.java

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,8 @@ public static class KafkaEventRecord {
4343
private String key;
4444
private String value;
4545
private List<Map<String, byte[]>> headers;
46+
private SchemaMetadata keySchemaMetadata;
47+
private SchemaMetadata valueSchemaMetadata;
4648
}
4749

4850
@Data
@@ -59,4 +61,13 @@ public String toString() {
5961
return topic + "-" + partition;
6062
}
6163
}
64+
65+
@Data
66+
@AllArgsConstructor
67+
@NoArgsConstructor
68+
@Builder(setterPrefix = "with")
69+
public static class SchemaMetadata {
70+
private String schemaId;
71+
private String dataFormat;
72+
}
6273
}

0 commit comments

Comments
 (0)