public void resetConnectorTopics(String connectorName) {
        String url = endpointForResource(String.format("connectors/%s/topics/reset", connectorName));
        Response response = requestPut(url, null);
        if (response.getStatus() >= Response.Status.BAD_REQUEST.getStatusCode()) {
            throw new ConnectRestException(response.getStatus(),
                    "Resetting active topics for connector " + connectorName + " failed. "
                            + "Error response: " + responseToString(response));
        }
    }
Reset the set of active topics of a connector running in this cluster.

@param connectorName name of the connector
@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