C0urante commented on code in PR #14538:
URL: https://github.com/apache/kafka/pull/14538#discussion_r1362527738
##########
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java:
##########
@@ -225,28 +121,6 @@ public void removeWorker(WorkerHandle worker) {
connectCluster.remove(worker);
}
- private void stopWorker(WorkerHandle worker) {
- try {
- log.info("Stopping worker {}", worker);
- worker.stop();
- } catch (UngracefulShutdownException e) {
- log.warn("Worker {} did not shutdown gracefully", worker);
- } catch (Exception e) {
- log.error("Could not stop connect", e);
- throw new RuntimeException("Could not stop worker", e);
- }
- }
-
- /**
- * Set a new timeout for REST requests to each worker in the cluster.
Useful if a request
- * is expected to block, since the time spent awaiting that request can be
reduced
- * and test runtime bloat can be avoided.
- * @param requestTimeoutMs the new timeout in milliseconds; must be
positive
- */
- public void requestTimeout(long requestTimeoutMs) {
- connectCluster.forEach(worker ->
worker.requestTimeout(requestTimeoutMs));
- }
Review Comment:
This is also migrated directly to the `EmbeddedConnect` class.
--
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.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
