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

MINOR: Bugfix in GroupMetadataManager.testShareGroupInitializeSuccess. (#19795) 

Currently, we were asserting on records containing set using
`assertEquals` which can fail intermittently. To fix the assertion has
been replaced by `assertRecordEquals`.

Reviewers: Andrew Schofield <aschofield@confluent.io>, Chia-Ping Tsai
 <chia7712@gmail.com>
This commit is contained in:
Sushant Mahajan 2025-05-23 21:24:38 +05:30 committed by GitHub
parent bbe27e65a3
commit af4d048da6
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java
View File

@ -21714,7 +21714,8 @@ public class GroupMetadataManagerTest {
CoordinatorRecord record = newShareGroupStatePartitionMetadataRecord(groupId, Map.of(), snapshotMetadataInitializeRecordMap, Map.of());
assertNull(result.response());
assertEquals(List.of(record), result.records());
assertEquals(1, result.records().size());
assertRecordEquals(record, result.records().get(0));
// Make sure the timeline map is not modified yet.
assertEquals(snapshotMetadataInitializeRecordMap, context.groupMetadataManager.shareGroupStatePartitionMetadata().get(groupId).initializingTopics());
}