lorcanj opened a new pull request, #19511: URL: https://github.com/apache/kafka/pull/19511
In the StickyTaskAssignor, a set of ProcessIds is created for any remaining unassigned tasks, representing the clients that a task can be assigned to. The set is currently created for each remaining taskId, however the set created is not dependent on the remaining taskIds (unlike the previousClientsForStandbyTask, which does use the taskId in its creation). I have checked that the set is not mutated in the findBestClientForTask() code path and run the unit tests applicable for this assignor. This change ensures the set is only created once. -- 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
