Skip to content

Commit 97510ff

Browse files
MINOR: Fix assignment reuse tests (#21077)
The tests were asserting reference equality against the wrong assignment map. Reviewers: David Jacot <[email protected]>
1 parent c7bdabf commit 97510ff

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/CommonAssignorTests.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,9 @@ public static void testAssignmentReuse(PartitionAssignor assignor, SubscriptionT
123123
);
124124

125125
for (String memberId : members.keySet()) {
126-
assertSame(firstAssignment.members().get(memberId).partitions(), secondAssignment.members().get(memberId).partitions());
126+
// The assignment map from the assignor must be the same as the immutable assignment map
127+
// that went in.
128+
assertSame(membersWithAssignment.get(memberId).partitions(), secondAssignment.members().get(memberId).partitions());
127129
}
128130
}
129131

0 commit comments

Comments
 (0)