root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

HOTFIX: remove unnecessary list creation (#16117) 

Removing a redundant list declaration in the new StickyTaskAssignor implementation

Reviewers: Antoine Pourchet <antoine@responsive.dev>
This commit is contained in:
A. Sophie Blee-Goldman 2024-05-28 21:35:02 -07:00 committed by GitHub
parent d64e3fbb2b
commit 9562143f08
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
streams/src/main/java/org/apache/kafka/streams/processor/assignment/assignors/StickyTaskAssignor.java
View File

@ -78,9 +78,7 @@ public class StickyTaskAssignor implements TaskAssignor {
finalAssignments.put(clientId, previousAssignment.withFollowupRebalance(Instant.ofEpochMilli(0)));
}
final Collection<KafkaStreamsAssignment> taskAssignments = finalAssignments.entrySet().stream()
.map(Map.Entry::getValue).collect(Collectors.toList());
return new TaskAssignment(taskAssignments);
return new TaskAssignment(finalAssignments.values());
}
private void optimizeActive(final ApplicationState applicationState,