@Override
    synchronized void updatePartitions(final Set<TopicPartition> inputPartitions, final Function<TopicPartition, RecordQueue> recordQueueCreator) {
        wrapped.updatePartitions(inputPartitions, recordQueueCreator);
    }
@Test
    public void testUpdatePartitions() {
        final Set<TopicPartition> inputPartitions = Collections.singleton(new TopicPartition("topic", 0));
        @SuppressWarnings("unchecked") final Function<TopicPartition, RecordQueue> recordQueueCreator = (Function<TopicPartition, RecordQueue>) mock(Function.class);

        synchronizedPartitionGroup.updatePartitions(inputPartitions, recordQueueCreator);

        verify(wrapped, times(1)).updatePartitions(inputPartitions, recordQueueCreator);
    }