KAFKA-17714: Fix StorageTool.scala to compile under Scala 2.12

apache · Oct 7, 2024 · ffde59e · ffde59e
1 parent 1d54a73
commit ffde59e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/test/scala/unit/kafka/tools/StorageToolTest.scala b/core/src/test/scala/unit/kafka/tools/StorageToolTest.scala
@@ -39,7 +39,7 @@ import org.junit.jupiter.params.ParameterizedTest
 import org.junit.jupiter.params.provider.ValueSource
 
 import scala.collection.mutable.ListBuffer
-import scala.jdk.CollectionConverters.IterableHasAsScala
+import scala.jdk.CollectionConverters._
 
 @Timeout(value = 40)
 class StorageToolTest {
@@ -455,7 +455,7 @@ Found problem:
     // Not doing full SCRAM record validation since that's covered elsewhere.
     // Just checking that we generate the correct number of records
     val bootstrapMetadata = new BootstrapDirectory(availableDirs.head.toString, Optional.empty).read
-    val scramRecords = bootstrapMetadata.records().asScala
+    val scramRecords = (Seq() ++ bootstrapMetadata.records().iterator().asScala)
       .filter(apiMessageAndVersion => apiMessageAndVersion.message().isInstanceOf[UserScramCredentialRecord])
       .map(apiMessageAndVersion => apiMessageAndVersion.message().asInstanceOf[UserScramCredentialRecord])
       .toList