protected String putConnectorConfig(String url, Map<String, String> connConfig) {
        ObjectMapper mapper = new ObjectMapper();
        String content;
        try {
            content = mapper.writeValueAsString(connConfig);
        } catch (IOException e) {
            throw new ConnectException("Could not serialize connector configuration and execute PUT request");
        }
        Response response = requestPut(url, content);
        if (response.getStatus() < Response.Status.BAD_REQUEST.getStatusCode()) {
            return responseToString(response);
        }
        throw new ConnectRestException(response.getStatus(),
                "Could not execute PUT request. Error response: " + responseToString(response));
    }
Execute a PUT request with the given connector configuration on the given URL endpoint.

@param url        the full URL of the endpoint that corresponds to the given REST resource
@param connConfig the intended configuration
@throws ConnectRestException if the REST api returns error status
@throws ConnectException if the configuration fails to be serialized or if the request could not be sent
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnect.java