@Override
    public int getPartitionId() {
        return partitionId;
    }
@Test
    public void testGetPartitionId() {
        assertEquals(1, batchEventData.getPartitionId());
        assertEquals(1, batchEventDataSameAttribute.getPartitionId());
        assertEquals(1, batchEventDataOtherSource.getPartitionId());
        assertEquals(2, batchEventDataOtherPartitionId.getPartitionId());
        assertEquals(1, batchEventDataOtherEvent.getPartitionId());
        assertEquals(1, batchEventDataNoEvent.getPartitionId());
    }