Skip to content

Commit 6fd7282

Browse files
authored
Update EventLoaderTest.java
1 parent e12da26 commit 6fd7282

File tree

1 file changed

+1
-6
lines changed

1 file changed

+1
-6
lines changed

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

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -128,12 +128,7 @@ public void testLoadMSKFirehoseEvent() {
128128
assertThat(event.getRecords()).hasSize(1);
129129
assertThat(event.getRecords().get(0).getKafkaRecordValue().array()).asString().isEqualTo("{\"Name\":\"Hello World\"}");
130130
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-
131+
assertThat(event.getRecords().get(0).getMskRecordMetadata()).asString().isEqualTo("{offset=0, partitionId=1, approximateArrivalTimestamp=1716369573887}");
137132
}
138133

139134
@Test

0 commit comments

Comments
 (0)