@Test
public void partitionsAssignedNoWriter() {

    final Consumer<Long, String> consumer = mock(Consumer.class);
    final OffsetResetter offsetResetter = new OffsetResetter<>(consumer, mock(java.util.function.Consumer.class),
            Collections.emptyList());
    final TopicPartition partition = new TopicPartition(TOPIC, 1);
    final List<TopicPartition> partitions = Collections.singletonList(partition);
    offsetResetter.onPartitionsAssigned(partitions);
    verify(consumer, times(1)).seekToBeginning(Collections.singleton(partition));
    verifyNoMoreInteractions(consumer);
}