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

MINOR: code cleanup GroupMetadataManagerTestContext (#19554) 

Removes redundant calls, and updates code to Java 17.

Reviewers: Lucas Brutschy <lbrutschy@confluent.io>
This commit is contained in:
Matthias J. Sax 2025-04-25 10:12:55 -07:00 committed by GitHub
parent b4b80731c1
commit 6462f7a0e2
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTestContext.java
View File

@ -1453,7 +1453,7 @@ public class GroupMetadataManagerTestContext {
fail("Unexpected exception: " + e.getMessage());
}
return null;
}).collect(Collectors.toList());
}).toList();
// Second join requests
List<CompletableFuture<JoinGroupResponseData>> secondJoinFutures = IntStream.range(0, numMembers).mapToObj(i -> {
@ -1463,7 +1463,7 @@ public class GroupMetadataManagerTestContext {
assertFalse(joinResult.joinFuture.isDone());
return joinResult.joinFuture;
}).collect(Collectors.toList());
}).toList();
// Advance clock by initial rebalance delay.
assertNoOrEmptyResult(sleep(classicGroupInitialRebalanceDelayMs));
@ -1798,8 +1798,6 @@ public class GroupMetadataManagerTestContext {
.setRackId(null)
.setInstanceId(null)
.setRebalanceTimeoutMs(1500)
.setAssignedTasks(TasksTuple.EMPTY)
.setTasksPendingRevocation(TasksTuple.EMPTY)
.setTopologyEpoch(0)
.setClientTags(Map.of())
.setProcessId(DEFAULT_PROCESS_ID)