@Test
public void testAllowedTimestampRange() {

	assertEquals(0L, new StreamRecord<>("test", 0).getTimestamp());
	assertEquals(-1L, new StreamRecord<>("test", -1).getTimestamp());
	assertEquals(1L, new StreamRecord<>("test", 1).getTimestamp());
	assertEquals(Long.MIN_VALUE, new StreamRecord<>("test", Long.MIN_VALUE).getTimestamp());
	assertEquals(Long.MAX_VALUE, new StreamRecord<>("test", Long.MAX_VALUE).getTimestamp());
}