public void warmUp() throws IOException {
        if (this.inner == NOOP_STREAM) {
            try {
                this.inner = createStream();
                LOGGER.info("warmup, created and opened a new stream: streamId={}, epoch={}, name={}", this.inner.streamId(), epoch, name);
                notifyListener(ElasticStreamMetaEvent.STREAM_DO_CREATE);
            } catch (Throwable e) {
                throw new IOException(e);
            }
        }
    }
Lazy stream, create stream when append record.
core/src/main/scala/kafka/log/streamaspect/LazyStream.java