rhauch commented on a change in pull request #10822:
URL: https://github.com/apache/kafka/pull/10822#discussion_r655778416
##########
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java
##########
@@ -559,6 +560,31 @@ public String endpointForResource(String resource) {
return url + resource;
}
+ /**
+ * Get the full URL of the endpoint that corresponds to the given REST
resource using a worker
+ * that is not running any tasks or connector instance for the
connectorName provided in the arguments
+ *
+ * @param resource the resource under the worker's admin endpoint
+ * @param connectorName the name of the connector
+ * @return the admin endpoint URL
+ * @throws ConnectException if no REST endpoint is available
+ */
+ public String endpointForWorkerRunningNoResourceForConnector(String
resource, String connectorName) {
Review comment:
Well, the `EmbeddedConnectCluster` is technically not an official public
API for Connect, but lots of connector projects use it (as intended), meaning
we have to be very clear about backward compatibility. It's probably fine to
keep the same pattern.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
