Fix fatal warnings

akka · Oct 23, 2019 · 06be1b3 · 06be1b3
1 parent 3868b23
commit 06be1b3
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 3 deletions.
diff --git a/build.sbt b/build.sbt
@@ -345,7 +345,7 @@ lazy val docs = project
         "scaladoc.akka.kafka.base_url" -> s"/${(Preprocess / siteSubdirName).value}/",
         "scaladoc.com.typesafe.config.base_url" -> s"https://lightbend.github.io/config/latest/api/",
         "javadoc.org.apache.kafka.base_url" -> s"https://kafka.apache.org/$kafkaVersionForDocs/javadoc/",
-        "javadoc.org.testcontainers.base_url" -> s"https://javadoc.jitpack.io/com/github/testcontainers/testcontainers-java/testcontainers/$testcontainersVersion/javadoc/",
+        "javadoc.org.testcontainers.base_url" -> s"https://javadoc.jitpack.io/com/github/testcontainers/testcontainers-java/testcontainers/$testcontainersVersion/javadoc/"
       ),
     paradoxRoots := List("index.html",
                          "release-notes/1.0-M1.html",

diff --git a/testkit/src/main/scala/akka/kafka/testkit/KafkaTestkitTestcontainersSettings.scala b/testkit/src/main/scala/akka/kafka/testkit/KafkaTestkitTestcontainersSettings.scala
@@ -5,6 +5,8 @@
 
 package akka.kafka.testkit
 
+import java.util.function.Consumer
+
 import akka.actor.ActorSystem
 import com.typesafe.config.Config
 import org.testcontainers.containers.{GenericContainer, KafkaContainer}
@@ -14,7 +16,10 @@ final class KafkaTestkitTestcontainersSettings private (
     val numBrokers: Int,
     val internalTopicsReplicationFactor: Int,
     val configureKafka: Vector[KafkaContainer] => Unit = _ => (),
-    val configureKafkaJava: java.util.function.Consumer[java.util.Collection[KafkaContainer]] = _ => (),
+    val configureKafkaJava: java.util.function.Consumer[java.util.Collection[KafkaContainer]] =
+      new Consumer[java.util.Collection[KafkaContainer]]() {
+        override def accept(arg: java.util.Collection[KafkaContainer]): Unit = ()
+      },
     val configureZooKeeper: GenericContainer[_] => Unit = _ => ()
 ) {
 

diff --git a/tests/src/test/scala/akka/kafka/scaladsl/SpecBase.scala b/tests/src/test/scala/akka/kafka/scaladsl/SpecBase.scala
@@ -9,7 +9,6 @@ package akka.kafka.scaladsl
 import akka.kafka.testkit.scaladsl.ScalatestKafkaSpec
 import org.scalatest.concurrent.{Eventually, ScalaFutures}
 import org.scalatest.{Matchers, WordSpecLike}
-import org.testcontainers.containers.GenericContainer
 
 abstract class SpecBase(kafkaPort: Int)
     extends ScalatestKafkaSpec(kafkaPort)