Skip to content

Commit 6462f7a

Browse files
authored
MINOR: code cleanup GroupMetadataManagerTestContext (#19554)
Removes redundant calls, and updates code to Java 17. Reviewers: Lucas Brutschy <[email protected]>
1 parent b4b8073 commit 6462f7a

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

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

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1453,7 +1453,7 @@ public List<JoinGroupResponseData> joinWithNMembers(
14531453
fail("Unexpected exception: " + e.getMessage());
14541454
}
14551455
return null;
1456-
}).collect(Collectors.toList());
1456+
}).toList();
14571457

14581458
// Second join requests
14591459
List<CompletableFuture<JoinGroupResponseData>> secondJoinFutures = IntStream.range(0, numMembers).mapToObj(i -> {
@@ -1463,7 +1463,7 @@ public List<JoinGroupResponseData> joinWithNMembers(
14631463
assertFalse(joinResult.joinFuture.isDone());
14641464

14651465
return joinResult.joinFuture;
1466-
}).collect(Collectors.toList());
1466+
}).toList();
14671467

14681468
// Advance clock by initial rebalance delay.
14691469
assertNoOrEmptyResult(sleep(classicGroupInitialRebalanceDelayMs));
@@ -1798,8 +1798,6 @@ public static StreamsGroupMember.Builder streamsGroupMemberBuilderWithDefaults(S
17981798
.setRackId(null)
17991799
.setInstanceId(null)
18001800
.setRebalanceTimeoutMs(1500)
1801-
.setAssignedTasks(TasksTuple.EMPTY)
1802-
.setTasksPendingRevocation(TasksTuple.EMPTY)
18031801
.setTopologyEpoch(0)
18041802
.setClientTags(Map.of())
18051803
.setProcessId(DEFAULT_PROCESS_ID)

0 commit comments

Comments
 (0)