@Override
    synchronized Long headRecordOffset(final TopicPartition partition) {
        return wrapped.headRecordOffset(partition);
    }
@Test
    public void testHeadRecordOffset() {
        final TopicPartition partition = new TopicPartition("topic", 0);
        final Long recordOffset = 0L;
        when(wrapped.headRecordOffset(partition)).thenReturn(recordOffset);

        final Long result = synchronizedPartitionGroup.headRecordOffset(partition);

        assertEquals(recordOffset, result);
        verify(wrapped, times(1)).headRecordOffset(partition);
    }