@Override
    synchronized int addRawRecords(final TopicPartition partition, final Iterable<ConsumerRecord<byte[], byte[]>> rawRecords) {
        return wrapped.addRawRecords(partition, rawRecords);
    }
@Test
    public void testAddRawRecords() {
        final TopicPartition partition = new TopicPartition("topic", 0);
        @SuppressWarnings("unchecked") final Iterable<ConsumerRecord<byte[], byte[]>> rawRecords = (Iterable<ConsumerRecord<byte[], byte[]>>) mock(Iterable.class);
        when(wrapped.addRawRecords(partition, rawRecords)).thenReturn(1);

        final int result = synchronizedPartitionGroup.addRawRecords(partition, rawRecords);

        assertEquals(1, result);
        verify(wrapped, times(1)).addRawRecords(partition, rawRecords);
    }