@Override
    public long streamEpoch() {
        return innerStream.streamEpoch();
    }
replayDone is used to record if the meta stream has been fully replayed.
core/src/main/scala/kafka/log/streamaspect/MetaStream.java