@Test
public void testSetOffSetsOK() throws Exception {

    for (String topic : topicList) {
        Map<TopicAndPartition, Long> tap = new HashMap<>();
        tap.put(new TopicAndPartition(topic, 1), 1L);
        tap.put(new TopicAndPartition(topic, 2), 2L);
        validKOM.setOffsets(tap);
    }
}