synchronized Entry<Long, LocalBatch> nextBatch(long offset) {
            Entry<Long, LocalBatch> entry = batches.higherEntry(offset);
            if (entry == null) {
                return null;
            }
            return new SimpleImmutableEntry<>(entry.getKey(), entry.getValue());
        }
The initial max read offset which LocalLog instances will be configured with.
metadata/src/test/java/org/apache/kafka/metalog/LocalLogManager.java