@Override
        public void handleException(Throwable e) {
            if (e instanceof InterruptedException) {
                numInterruptedExceptionsSeen.incrementAndGet();
                Thread.currentThread().interrupt();
            }
        }
Test that we continue handling events after Event#handleException itself throws an exception.
server-common/src/test/java/org/apache/kafka/queue/KafkaEventQueueTest.java