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);
    }
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
Ensure that the Kinesis Stream exists ( creates it if does not exist ) .