@Test
public void skipMessagesBeforeLowestOffset() throws IOException {

    final BiFunction<Integer, LocalDateTime, ExpiringConsumer<String>> writerBuilder = mock(BiFunction.class);
    final Checkpointer mockCheckpointer = mock(Checkpointer.class);
    final PartitionedWriter<String> writer = new PartitionedWriter<>(writerBuilder,
            new FixedOffsetComputer("ignored", 42), "ignored",
            DataAccessEventProtos.FsEvent.newBuilder(), mockCheckpointer);
    writer.write(Instant.EPOCH, buildOffset(1, 10), "Ignored");
    writer.write(Instant.EPOCH, buildOffset(1, 11), "Also ignored");
    verifyZeroInteractions(writerBuilder);
    verifyZeroInteractions(mockCheckpointer);
}