iron-spi-aws/src/main/java/io/axway/iron/spi/aws/kinesis/AwsKinesisUtils.java
public static void ensureStreamExists(AmazonKinesis kinesisClient, String streamName) {
        createStreamIfNotExists(kinesisClient, streamName, 1);
        waitStreamActivation(kinesisClient, streamName, MIN_3);
    }
public static void ensureStreamExists(AmazonKinesis kinesisClient, String streamName) {
        createStreamIfNotExists(kinesisClient, streamName, 1);
        waitStreamActivation(kinesisClient, streamName, MIN_3);
    }
Ensure that the Kinesis Stream exists (creates it if does not exist).

@param kinesisClient Kinesis client
@param streamName Stream name