kpatelatwork commented on a change in pull request #10822:
URL: https://github.com/apache/kafka/pull/10822#discussion_r656633775
##########
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:
Good idea, I renamed the method.
--
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
