@Override
    public boolean connectionFailed(Node node) {
        return connectionState(node.idString()).isBackingOff(time.milliseconds());
    }
A mock network client for use testing code
clients/src/test/java/org/apache/kafka/clients/MockClient.java