(kafka) branch 3.8 updated: Removed Set.of usage (#17703)

[lianetm]

This is an automated email from the ASF dual-hosted git repository.

lianetm pushed a commit to branch 3.8
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/3.8 by this push:
     new 14bd65149e3 Removed Set.of usage (#17703)
14bd65149e3 is described below

commit 14bd65149e353164b8750d306a3da49f1e5b8ce5
Author: ShivsundarR <s...@confluent.io>
AuthorDate: Wed Nov 6 15:13:01 2024 -0500

    Removed Set.of usage (#17703)
    
    Reviewers: Lianet Magrans <lmagr...@confluent.io>, Federico Valeri 
<fedeval...@gmail.com>, Chia-Ping Tsai <chia7...@gmail.com>
---
 .../org/apache/kafka/controller/ReplicationControlManagerTest.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/metadata/src/test/java/org/apache/kafka/controller/ReplicationControlManagerTest.java
 
b/metadata/src/test/java/org/apache/kafka/controller/ReplicationControlManagerTest.java
index 27c82caeab3..924763dc7b1 100644
--- 
a/metadata/src/test/java/org/apache/kafka/controller/ReplicationControlManagerTest.java
+++ 
b/metadata/src/test/java/org/apache/kafka/controller/ReplicationControlManagerTest.java
@@ -119,6 +119,7 @@ import java.util.Set;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 import java.util.stream.IntStream;
+import java.util.stream.Stream;
 
 import static java.util.Arrays.asList;
 import static java.util.Collections.singletonList;
@@ -571,7 +572,7 @@ public class ReplicationControlManagerTest {
         ControllerRequestContext requestContext = 
anonymousContextFor(ApiKeys.CREATE_TOPICS);
         PolicyViolationException error = assertThrows(
                 PolicyViolationException.class,
-                () -> replicationControl.createTopics(requestContext, request, 
Set.of("foo", "bar", "baz")));
+                () -> replicationControl.createTopics(requestContext, request, 
Stream.of("foo", "bar", "baz").collect(Collectors.toSet())));
         assertEquals(error.getMessage(), "Excessively large number of 
partitions per request.");
     }