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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
