Adding Key/Value Schema metadata attributes for KafkaEvent by karthikpswamy · Pull Request #548 · aws/aws-lambda-java-libs
Expand Up
@@ -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 Expand All @@ -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; } }
@Data Expand All @@ -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; } }