File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
aws-lambda-java-tests/src/test/java/com/amazonaws/services/lambda/runtime/tests Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -121,9 +121,10 @@ public void testLoadKinesisFirehoseEvent() {
121
121
@ Test
122
122
public void testLoadMSKFirehoseEvent () {
123
123
MSKFirehoseEvent event = EventLoader .loadMSKFirehoseEvent ("msk_firehose_event.json" );
124
-
124
+
125
125
assertThat (event ).isNotNull ();
126
- assertThat (event .getDeliveryStreamArn ()).isEqualTo ("arn:aws:kinesis:EXAMPLE" );
126
+ assertThat (event .getSourceMSKArn ()).isEqualTo ("arn:aws:kafka:EXAMPLE" );
127
+ assertThat (event .getDeliveryStreamArn ()).isEqualTo ("arn:aws:firehose:EXAMPLE" );
127
128
assertThat (event .getRecords ()).hasSize (1 );
128
129
assertThat (event .getRecords ().get (0 ).getKafkaRecordValue ().array ()).asString ().isEqualTo ("{\" Name\" :\" Hello World\" }" );
129
130
}
You can’t perform that action at this time.
0 commit comments