ChoMinGi commented on code in PR #23454:
URL: https://github.com/apache/kafka/pull/23454#discussion_r4033528897
##########
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/AssignmentRefinerImpl.java:
##########
@@ -288,6 +286,240 @@ private static boolean isReady(
.anyMatch(holder -> holder.processId().equals(targetProcessId) &&
holder.caughtUp());
}
+ /**
+ * Decides which of the staged migrations get a warm-up task, under the
warmup budget.
+ *
+ * <p>There is different scenarios:
+ * <ul>
+ * <li>A warm-up task already restoring keeps its warm-up slot if the
target assignment didn't change, and the
+ * warmu-up task is not caught up yet. It could also get revoked if
the warmup budget was reduced and keeping
Review Comment:
typo: `warmu-up` -> `warm-up`
--
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]
