(kafka) branch 3.9 updated: MINOR: made the test compatible with older java. (#20677)

[mjsax]

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

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


The following commit(s) were added to refs/heads/3.9 by this push:
     new b54acf80a58 MINOR: made the test compatible with older java. (#20677)
b54acf80a58 is described below

commit b54acf80a581fbd76c90391e66e5fc78a3aa4b68
Author: Nikita Shupletsov <nik...@shupletsov.ca>
AuthorDate: Thu Oct 9 13:16:17 2025 -0700

    MINOR: made the test compatible with older java. (#20677)
    
    Fix Java 11 vs Java 8 compilation issue.
    
    Reviewers: Matthias J. Sax <matth...@confluent.io>
---
 .../org/apache/kafka/streams/processor/internals/TasksTest.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/streams/src/test/java/org/apache/kafka/streams/processor/internals/TasksTest.java
 
b/streams/src/test/java/org/apache/kafka/streams/processor/internals/TasksTest.java
index 90c254f9726..397e2a04a94 100644
--- 
a/streams/src/test/java/org/apache/kafka/streams/processor/internals/TasksTest.java
+++ 
b/streams/src/test/java/org/apache/kafka/streams/processor/internals/TasksTest.java
@@ -211,16 +211,16 @@ public class TasksTest {
 
     @Test
     public void shouldClearAllPendingTasks() {
-        final StandbyTask task = standbyTask(TASK_0_0, 
Set.of(TOPIC_PARTITION_B_0))
+        final StandbyTask task = standbyTask(TASK_0_0, 
mkSet(TOPIC_PARTITION_B_0))
             .inState(State.CREATED).build();
         tasks.addPendingTasksToInit(Collections.singleton(task));
         final TaskId taskId1 = new TaskId(0, 0, "A");
         tasks.addPendingActiveTasksToCreate(mkMap(
-            mkEntry(taskId1, Set.of(TOPIC_PARTITION_A_0))
+            mkEntry(taskId1, mkSet(TOPIC_PARTITION_A_0))
         ));
         final TaskId taskId2 = new TaskId(0, 1, "A");
         tasks.addPendingStandbyTasksToCreate(mkMap(
-            mkEntry(taskId2, Set.of(TOPIC_PARTITION_A_0))
+            mkEntry(taskId2, mkSet(TOPIC_PARTITION_A_0))
         ));
 
         assertTrue(tasks.pendingTasksToInit().contains(task));