diff --git a/build.gradle b/build.gradle index 092f4ff1d3385..a4fb36cbd0078 100644 --- a/build.gradle +++ b/build.gradle @@ -1540,7 +1540,6 @@ project(':jmh-benchmarks') { compile project(':core') compile project(':clients') compile project(':streams') - compile project(':core') compile project(':clients').sourceSets.test.output compile project(':core').sourceSets.test.output compile libs.jmhCore diff --git a/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/HighwatermarkCheckpointBench.java b/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/HighwatermarkCheckpointBench.java index 9cb8ac6a97a9e..889604ed91cbb 100644 --- a/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/HighwatermarkCheckpointBench.java +++ b/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/HighwatermarkCheckpointBench.java @@ -59,7 +59,7 @@ import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; import java.util.stream.Collectors; -import scala.jdk.CollectionConverters; +import scala.collection.JavaConverters; @Warmup(iterations = 5) @@ -100,9 +100,8 @@ public void setup() { this.metrics = new Metrics(); this.time = new MockTime(); this.failureChannel = new LogDirFailureChannel(brokerProperties.logDirs().size()); - final List files = - CollectionConverters.seqAsJavaList(brokerProperties.logDirs()).stream().map(File::new).collect(Collectors.toList()); - this.logManager = TestUtils.createLogManager(CollectionConverters.asScalaBuffer(files), + final List files = JavaConverters.asJavaCollection(brokerProperties.logDirs()).stream().map(File::new).collect(Collectors.toList()); + this.logManager = TestUtils.createLogManager(JavaConverters.iterableAsScalaIterableConverter(files).asScala().toSeq(), LogConfig.apply(), CleanerConfig.apply(1, 4 * 1024 * 1024L, 0.9d, 1024 * 1024, 32 * 1024 * 1024, Double.MAX_VALUE, 15 * 1000, true, "MD5"), time); @@ -160,7 +159,7 @@ public void tearDown() throws Exception { this.metrics.close(); this.scheduler.shutdown(); this.quotaManagers.shutdown(); - for (File dir : CollectionConverters.asJavaCollection(logManager.liveLogDirs())) { + for (File dir : JavaConverters.asJavaCollection(logManager.liveLogDirs())) { Utils.delete(dir); } }