@Test
public void testEnlargeStream() throws Exception {

    streamOperationsService.createInternalStream(StreamsHelper.STREAM_NAME, StreamsHelper.COLUMNS);
    streamOperationsService.enlargeStream(StreamsHelper.STREAM_NAME, new LinkedList<ColumnNameTypeValue>() {
        {
            add(new ColumnNameTypeValue("additionalColumn", ColumnType.STRING, "additionalColumn"));
        }
    });
    assertTrue("Expected true not found", streamOperationsService.streamExist(StreamsHelper.STREAM_NAME));
}