public Collection<String> connectors() {
        ObjectMapper mapper = new ObjectMapper();
        String url = endpointForResource("connectors");
        Response response = requestGet(url);
        if (response.getStatus() < Response.Status.BAD_REQUEST.getStatusCode()) {
            try {
                return mapper.readerFor(Collection.class).readValue(responseToString(response));
            } catch (IOException e) {
                log.error("Could not parse connector list from response: {}",
                        responseToString(response), e
                );
                throw new ConnectException("Could not not parse connector list", e);
            }
        }
        throw new ConnectRestException(response.getStatus(),
                "Could not read connector list. Error response: " + responseToString(response));
    }
Get the connector names of the connectors currently running on this cluster.

@return the list of connector names
@throws ConnectRestException if the HTTP request to the REST API failed with a valid status code.
@throws ConnectException for any other error.
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnect.java