vamossagar12 commented on code in PR #15305:
URL: https://github.com/apache/kafka/pull/15305#discussion_r1474605205
##########
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java:
##########
@@ -267,6 +267,18 @@ public String memberId() {
return JoinGroupRequest.UNKNOWN_MEMBER_ID;
}
+ @Override
+ protected void handlePollTimeoutExpiry() {
+ log.warn("worker poll timeout has expired. This means the time between
subsequent calls to poll() " +
+ "in DistributedHerder tick() method was longer than the configured
rebalance.timeout.ms. " +
+ "If you see this happening consistently, then it can be addressed
by either adding more workers " +
+ "to the connect cluster or by increasing the rebalance.timeout.ms
configuration value. Please note that " +
Review Comment:
The bit about `then it can be addressed by either adding more workers`, is
something which has been experienced in certain cases when there are too many
tasks to start which leads to poll timeout. I can remove it if it's not deemed
necessary here.
--
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
