@Override
    synchronized void setPartitionTime(final TopicPartition partition, final long partitionTime) {
        wrapped.setPartitionTime(partition, partitionTime);
    }
@Test
    public void testSetPartitionTime() {
        final TopicPartition partition = new TopicPartition("topic", 0);
        final long partitionTime = 12345678L;

        synchronizedPartitionGroup.setPartitionTime(partition, partitionTime);

        verify(wrapped, times(1)).setPartitionTime(partition, partitionTime);
    }