public ConfigInfos validateConnectorConfig(String connClassName, Map<String, String> connConfig) {
        String url = endpointForResource(String.format("connector-plugins/%s/config/validate", connClassName));
        String response = putConnectorConfig(url, connConfig);
        ConfigInfos configInfos;
        try {
            configInfos = new ObjectMapper().readValue(response, ConfigInfos.class);
        } catch (IOException e) {
            throw new ConnectException("Unable deserialize response into a ConfigInfos object");
        }
        return configInfos;
    }
Validate a given connector configuration. If the configuration validates or
has a configuration error, an instance of {@link ConfigInfos} is returned. If the validation fails
an exception is thrown.

@param connClassName the name of the connector class
@param connConfig    the intended configuration
@throws ConnectRestException if the REST api returns error status
@throws ConnectException if the configuration fails to serialize/deserialize or if the request failed to send
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnect.java