public boolean isConnectionSetupTimeout(String id, long now) {
        NodeConnectionState nodeState = this.nodeState(id);
        if (nodeState.state != ConnectionState.CONNECTING)
            throw new IllegalStateException("Node " + id + " is not in connecting state");
        return now - lastConnectAttemptMs(id) > connectionSetupTimeoutMs(id);
    }
Test if the connection to the given node has reached its timeout
@param id the connection to fetch the state for
@param now the current time in ms
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java