@Test
public void testMapWithBelowZeroOffset() throws Exception {

    // Create TAP, Long map to test with
    Map<TopicAndPartition, Long> tap = new HashMap<>();
    tap.put(new TopicAndPartition(testTopic, 1), 1L);
    tap.put(new TopicAndPartition(testTopic, 2), -2L);
    assertFalse(KafkaOffsetManagerUtils.isValidOffsetMap(tap));
}