(kafka) branch trunk updated: MINOR: Fix assignment reuse tests (#21077)

[dajac]

This is an automated email from the ASF dual-hosted git repository.

dajac pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 97510ff6de5 MINOR: Fix assignment reuse tests (#21077)
97510ff6de5 is described below

commit 97510ff6de5d9cf0ae8b151089abd97b0bc8f330
Author: Sean Quah <sq...@confluent.io>
AuthorDate: Thu Dec 4 14:54:19 2025 +0000

    MINOR: Fix assignment reuse tests (#21077)
    
    The tests were asserting reference equality against the wrong assignment
    map.
    
    Reviewers: David Jacot <dja...@confluent.io>
---
 .../apache/kafka/coordinator/group/assignor/CommonAssignorTests.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/CommonAssignorTests.java
 
b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/CommonAssignorTests.java
index c6c6e294a10..a7e4c4af675 100644
--- 
a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/CommonAssignorTests.java
+++ 
b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/CommonAssignorTests.java
@@ -123,7 +123,9 @@ public class CommonAssignorTests {
         );
 
         for (String memberId : members.keySet()) {
-            assertSame(firstAssignment.members().get(memberId).partitions(), 
secondAssignment.members().get(memberId).partitions());
+            // The assignment map from the assignor must be the same as the 
immutable assignment map
+            // that went in.
+            assertSame(membersWithAssignment.get(memberId).partitions(), 
secondAssignment.members().get(memberId).partitions());
         }
     }