@Test
public void testMapWithMultipleTopics() throws Exception {

    Map<TopicAndPartition, Long> tap = new HashMap<>();
    tap.put(new TopicAndPartition(testTopic, 1), 1L);
    tap.put(new TopicAndPartition(testTopic + "1", 2), 2L);
    assertFalse(KafkaOffsetManagerUtils.isValidOffsetMap(tap));
}