Skip to content

Commit e12da26

Browse files
authored
Update EventLoaderTest.java
added MSKMetadata check and Approximate arrivaltimestamp.
1 parent 5769d76 commit e12da26

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

aws-lambda-java-tests/src/test/java/com/amazonaws/services/lambda/runtime/tests/EventLoaderTest.java

+7
Original file line numberDiff line numberDiff line change
@@ -127,6 +127,13 @@ public void testLoadMSKFirehoseEvent() {
127127
assertThat(event.getDeliveryStreamArn()).isEqualTo("arn:aws:firehose:EXAMPLE");
128128
assertThat(event.getRecords()).hasSize(1);
129129
assertThat(event.getRecords().get(0).getKafkaRecordValue().array()).asString().isEqualTo("{\"Name\":\"Hello World\"}");
130+
assertThat(event.getRecords().get(0).getApproximateArrivalTimestamp()).asString().isEqualTo("1716369573887");
131+
assertThat(event.getRecords().get(0).getMskRecordMetadata()).asString().isEqualTo("{\n" +
132+
" \"offset\": \"0\",\n" +
133+
" \"partitionId\": \"1\",\n" +
134+
" \"approximateArrivalTimestamp\": 1716369573887\n" +
135+
" }");
136+
130137
}
131138

132139
@Test

0 commit comments

Comments
 (0)