public boolean flushed() {
        return this.completions.isEmpty();
    }
@Test
    public void shouldBeFlushedIfNoBufferedRecords() {
        buildMockProducer(true);
        assertTrue(producer.flushed());
    }