@Test
public void expireNoWriter() {

    final PartitionedWriter partitionedWriter = new PartitionedWriter<String>(null,
            new FixedOffsetComputer("ignored", 0), "ignored",
            DataAccessEventProtos.FsEvent.newBuilder(), mock(Checkpointer.class));
    // Should not crash
    partitionedWriter.expireConsumers();
}