showuon commented on code in PR #15305:
URL: https://github.com/apache/kafka/pull/15305#discussion_r1577220797
##########
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 " +
+ "rebalance.timeout.ms also controls the maximum allowed time for
each worker to join the group once a " +
+ "rebalance has begun so the set value should not be very high");
Review Comment:
@gharris1727 @mimaison , could you help review these log output since you're
the connect experts. Thanks.
##########
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 " +
+ "rebalance.timeout.ms also controls the maximum allowed time for
each worker to join the group once a " +
+ "rebalance has begun so the set value should not be very high");
Review Comment:
@gharris1727 @mimaison , could you help review these log output since you're
the connect experts? Thanks.
--
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
