We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5769d76 commit e12da26Copy full SHA for e12da26
aws-lambda-java-tests/src/test/java/com/amazonaws/services/lambda/runtime/tests/EventLoaderTest.java
@@ -127,6 +127,13 @@ public void testLoadMSKFirehoseEvent() {
127
assertThat(event.getDeliveryStreamArn()).isEqualTo("arn:aws:firehose:EXAMPLE");
128
assertThat(event.getRecords()).hasSize(1);
129
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
+
137
}
138
139
@Test
0 commit comments