@Override
    public void flush() {
        try {
            lastAppend.get();
        } catch (Throwable e) {
            throw new RuntimeException(e);
        }
    }
In the case of unclean shutdown, the last entry needs to be recovered from the time index.
core/src/main/scala/kafka/log/streamaspect/ElasticTimeIndex.java