mimaison commented on code in PR #17804:
URL: https://github.com/apache/kafka/pull/17804#discussion_r1951118069
##########
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Herder.java:
##########
@@ -381,6 +381,12 @@ default void validateConnectorConfig(Map<String, String>
connectorConfig, Callba
*/
void setClusterLoggerLevel(String namespace, String level);
+ /**
+ * Get the worker for this herder
+ * @return the worker
+ */
+ Worker worker();
Review Comment:
Good call, I changed that to return `ConnectMetrics`
--
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
