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