@Override
        public CompletableFuture<Void> close() {
            return CompletableFuture.completedFuture(null);
        }
Lazy stream, create stream when append record.
core/src/main/scala/kafka/log/streamaspect/LazyStream.java