@Override
    synchronized void updateLags() {
        wrapped.updateLags();
    }
@Test
    public void testUpdateLags() {
        synchronizedPartitionGroup.updateLags();

        verify(wrapped, times(1)).updateLags();
    }