### Question:
KafkaProducerWrapper implements Closeable, Flushable { @Override public void close() throws IOException { LOGGER.debug("Closing the producer wrapper and flushing outstanding writes."); flush(); } KafkaProducerWrapper(Producer<K, T> kafkaProducer); void send(ProducerRecord<K, T> record); void sendSynchronously(ProducerRecord<K, T> record); void sendSynchronously(List<ProducerRecord<K, T>> records); @Override void flush(); @Override void close();  }### Answer:
@Test public void test_WrapperNotCloseProducer() throws IOException, ExecutionException, InterruptedException { KafkaProducerWrapper<String, String> producer = new KafkaProducerWrapper<>(mockedProducer); producer.close(); verify(mockedProducer, never()).close(); }