@Test
public void partitionsAssignedNoTopic() {

    final Consumer<Long, String> consumer = mock(Consumer.class);
    final OffsetResetter offsetResetter = new OffsetResetter<>(consumer, mock(java.util.function.Consumer.class),
            Collections.singleton(mock(PartitionedWriter.class)));
    offsetResetter.onPartitionsAssigned(Collections.emptyList());
    verifyZeroInteractions(consumer);
}