ChoMinGi commented on code in PR #23454:
URL: https://github.com/apache/kafka/pull/23454#discussion_r4033653432
##########
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/AssignmentRefinerImpl.java:
##########
@@ -547,4 +805,92 @@ record TaskDecisions(
List<TaskGrant> grantedTasks
) {
}
+
+ /**
+ * What a staged migration needs from the warm-up budget. This is decided
entirely by what the target owner's
+ * process already holds for the task, so the five values are mutually
exclusive and cover every staged
+ * migration.
+ */
+ private enum Warming {
+ /** Nothing can warm this migration and no warm-up slot may be spent
on it. */
+ PARK,
+
+ /** A standby on the target owner itself already warms it, for free. */
+ BORROW,
+
+ /** A warm-up is already restoring for it, and keeps the warm-up slot
it was funded with. */
+ KEEP,
+
+ /** Its target owner's process holds nothing for the task: a warm-up
must be planted. Costs a warm-up slot. */
+ PLANT,
+
+ /**
+ * Its target owner's process holds a standby of the task, but on one
of its <em>other</em> members.
+ * Cost a warmu-up slot.
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]
