@Test
    void testReaperInvokedInClose() {
        consumer = newConsumer();
        completeUnsubscribeApplicationEventSuccessfully();
        consumer.close();
        verify(backgroundEventReaper).reap(backgroundEventQueue);
    }
Tests that calling {@link Thread#interrupt()} before {@link KafkaConsumer#poll(Duration)}
causes {@link InterruptException} to be thrown.
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java