@Test
public void get() {

    // get MRecord 12 times, so that the consumer.poll method is called twice
    for (int i = 0; i < 12; i++) {
        UntypedValues mRecord = source.get();
        assertNotNull(mRecord);
    }
    // since there are 6 records in the consumerRecords, poll should only be called twice
    Mockito.verify(consumer, Mockito.times(2)).poll(POLL_TIMEOUT_MS);
}