@Override
        public CompletableFuture<AppendResult> append(AppendContext context, RecordBatch recordBatch) {
            return FutureUtil.failedFuture(new UnsupportedOperationException("noop stream"));
        }
Lazy stream, create stream when append record.
core/src/main/scala/kafka/log/streamaspect/LazyStream.java