gabriellefu commented on code in PR #23588:
URL: https://github.com/apache/kafka/pull/23588#discussion_r4174097524
##########
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/ProcessState.java:
##########
@@ -44,6 +44,8 @@ public class ProcessState {
private final Map<String, Set<TaskId>> assignedStandbyTasks;
private final Set<TaskId> assignedTasks;
private PriorityQueue<Map.Entry<String, Integer>> membersByLoad;
+ // The member with the fewest tasks, or null when not computed since the
last added task.
+ private String leastLoadedMember;
Review Comment:
it was originally used to handle the problem of we put task back to sticky
member, then in the least-loaded stage, it won't be updated. But I realized I
can just recored what has been changed and check if the least-loaded member's
room has expired. I have updated it now. Thanks for pointing it out
--
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]
