vamossagar12 commented on code in PR #15305: URL: https://github.com/apache/kafka/pull/15305#discussion_r1604757990
########## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java: ########## @@ -2704,6 +2704,11 @@ public void onRevoked(String leader, Collection<String> connectors, Collection<C } } + @Override + public Stage onPollTimeoutExpiry() { Review Comment: Yeah it seemed a bit weird to me as well but i thought that the log line for worker poll timeout needs to be added in `WorkerCoordinator` only. I have changed it to have it now being printed in the `WorkerRebalanceListener`. Let me know if it makes sense and that was something you had in mind. -- 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