@Test
public void testCreateInternalStream() throws Exception {

    streamOperationsService.createInternalStream(StreamsHelper.STREAM_NAME, StreamsHelper.COLUMNS);
    assertTrue("Expected true not found", streamOperationsService.streamExist(StreamsHelper.STREAM_NAME));
}