@Override
    public void doWork() {
        try {
            client.poll();
        } catch (Throwable t) {
            throw fatalFaultHandler.handleFault("Unexpected error in raft IO thread", t);
        }
    }
Closed in {@link #shutdown()} after shutdown completes.
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClientDriver.java