vamossagar12 commented on code in PR #12802:
URL: https://github.com/apache/kafka/pull/12802#discussion_r1064852750
##########
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java:
##########
@@ -780,6 +774,14 @@ protected void stopServices() {
}
}
+ // Timeout for herderExecutor to gracefully terminate is set to a value to
accommodate
+ // reading to the end of the config topic + successfully attempting to
stop all connectors and tasks and a buffer of 10s
+ private long herderExecutorTimeoutMs() {
+ return this.workerSyncTimeoutMs +
+ config.getInt(DistributedConfig.WORKER_SYNC_TIMEOUT_MS_CONFIG)
+
Review Comment:
Nope that wasn't right. Changed it now. Good catch.
--
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
