mjsax commented on code in PR #22788: URL: https://github.com/apache/kafka/pull/22788#discussion_r3633060989
########## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/MemberAssignmentImpl.java: ########## @@ -16,28 +16,31 @@ */ package org.apache.kafka.coordinator.group.streams.assignor; +import org.apache.kafka.coordinator.group.api.streams.assignor.MemberAssignment; + +import java.util.HashMap; import java.util.Map; import java.util.Objects; import java.util.Set; /** * The task assignment for a streams group member. * - * @param activeTasks The active tasks assigned to this member keyed by subtopologyId. - * @param standbyTasks The standby tasks assigned to this member keyed by subtopologyId. - * @param warmupTasks The warm-up tasks assigned to this member keyed by subtopologyId. + * @param activeTasks The active tasks assigned to this member keyed by subtopology Id. + * @param standbyTasks The standby tasks assigned to this member keyed by subtopology Id. + * The maps are not made immutable, since the server-side assignors rely on + * being able to mutate them while building new assignments. Review Comment: Thanks. This make sense to me -- I guess it's an artifact of `StickyAssignor` which was internal up to now... Let's drop this JavaDocs comment, and ensure we make a copy of this Map after it's returned to the GC. -- 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]
