KinesisPipelineTest.java

@Test
public void testResourceCountCorrect() {
  Template template = getStackTemplate();
  template.resourceCountIs("AWS::Kinesis::Stream", 1);
  template.resourceCountIs("AWS::KinesisFirehose::DeliveryStream", 2);
}
 
@Test
public void testStreamsConfigured() {
  Template template = getStackTemplate();
  template.hasResourceProperties("AWS::Kinesis::Stream", Map.of(
      "Name", "analytics-android-kinesis-data-stream",
      "RetentionPeriodHours", 168,
      "StreamEncryption", Map.of(
          "EncryptionType", "KMS",
          "KeyId", Collections.singletonMap("Fn::GetAtt", new String[]{
              "testkey2D7A4880",
              "Arn"
          })),
      "StreamModeDetails", Collections.singletonMap("StreamMode", "ON_DEMAND")
  ));
}