public int getPartitionId() {
        return partitionId;
    }
@Test
    public void testGetPartitionId() {
        assertEquals(42, dataEvent.getPartitionId());
        assertEquals(42, objectEvent.getPartitionId());
    }