From 6462f7a0e25c69b57015f37458cd62b99d98f347 Mon Sep 17 00:00:00 2001 From: "Matthias J. Sax" Date: Fri, 25 Apr 2025 10:12:55 -0700 Subject: [PATCH] MINOR: code cleanup GroupMetadataManagerTestContext (#19554) Removes redundant calls, and updates code to Java 17. Reviewers: Lucas Brutschy --- .../coordinator/group/GroupMetadataManagerTestContext.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTestContext.java b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTestContext.java index bdba91c88d1..112653dceea 100644 --- a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTestContext.java +++ b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTestContext.java @@ -1453,7 +1453,7 @@ public class GroupMetadataManagerTestContext { fail("Unexpected exception: " + e.getMessage()); } return null; - }).collect(Collectors.toList()); + }).toList(); // Second join requests List> 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)